lib/backburner/worker.rb in backburner-0.4.3 vs lib/backburner/worker.rb in backburner-0.4.4
- old
+ new
@@ -24,10 +24,10 @@
# Backburner::Worker.enqueue NewsletterSender, [self.id, user.id], :ttr => 1000
#
def self.enqueue(job_class, args=[], opts={})
pri = resolve_priority(opts[:pri] || job_class)
delay = [0, opts[:delay].to_i].max
- ttr = opts[:ttr] || Backburner.configuration.respond_timeout
+ ttr = resolve_respond_timeout(opts[:ttr] || job_class)
res = Backburner::Hooks.invoke_hook_events(job_class, :before_enqueue, *args)
return false unless res # stop if hook is false
data = { :class => job_class.name, :args => args }
retryable_command do
tube = connection.tubes[expand_tube_name(opts[:queue] || job_class)]
\ No newline at end of file