class Delayed::Worker

Attributes

aws_config[RW]
config[RW]
delay[RW]
expires_in[RW]
sqs[RW]
timeout[RW]

Public Class Methods

configure() { |config| ... } click to toggle source
# File lib/delayed/backend/worker.rb, line 9
def configure
  yield(config)

  self.default_queue_name = if !config.default_queue_name.nil? && config.default_queue_name.length != 0
                  config.default_queue_name
                else
                  'default'
                end
  self.delay = config.delay_seconds || 0
  self.timeout = config.visibility_timeout || 5.minutes
  self.expires_in = config.message_retention_period || 4.days
end

Public Instance Methods

job_say(job, text, level = DEFAULT_LOG_LEVEL) click to toggle source

Override to remove reference to id: there’s no id in an SQS::Job

# File lib/delayed/backend/worker.rb, line 28
def job_say(job, text, level = DEFAULT_LOG_LEVEL)
  text = "Job #{job.name} #{text}"
  say text, level
end