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