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