lib/backburner/worker.rb in backburner-allq-1.0.20 vs lib/backburner/worker.rb in backburner-allq-1.0.21
- old
+ new
@@ -29,10 +29,10 @@
ttr = resolve_respond_timeout(opts[:ttr] || job_class)
res = Backburner::Hooks.invoke_hook_events(job_class, :before_enqueue, *args)
return nil unless res # stop if hook is false
- data = { :class => job_class.name, :args => args }
+ data = { :class => job_class.name, :args => args, :ttr => ttr }
queue = opts[:queue] && (Proc === opts[:queue] ? opts[:queue].call(job_class) : opts[:queue])
begin
response = nil
connection = Backburner::Connection.new(Backburner.configuration.allq_url)