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)