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