class Delayed::Worker

Attributes

available_priorities[RW]
config[RW]
delay[RW]
expires_in[RW]
queue_name[RW]
timeout[RW]

Public Class Methods

azure() click to toggle source
# File lib/delayed/backend/worker.rb, line 28
def azure
  @azure ||= Azure::QueueService.new
end
configure() { |config| ... } click to toggle source
# File lib/delayed/backend/worker.rb, line 9
def configure
  yield(config)
  self.queue_name = config.queue_name || 'default'
  self.delay = config.delay || 0
  self.timeout = config.timeout || 5.minutes
  self.expires_in = config.expires_in || 7.days

  priorities = config.available_priorities || [0]
  if priorities.include?(0) && priorities.all? { |p| p.is_a?(Integer) }
    self.available_priorities = priorities.sort
  else
    raise ArgumentError, "available_priorities option has wrong format. Please provide array of Integer values, includes zero. Default is [0]."
  end
end
queues() click to toggle source
# File lib/delayed/backend/worker.rb, line 32
def queues
  unless @queues
    @queues = Delayed::Worker.azure.list_queues
    @queues.map! { |q| q.name } 
  end
  @queues
end