lib/backburner.rb in backburner-allq-1.0.24 vs lib/backburner.rb in backburner-allq-1.0.25

- old
+ new

@@ -23,16 +23,13 @@ # Enqueues a job to be performed with given arguments. # # @example # Backburner.enqueue NewsletterSender, self.id, user.id # - def enqueue(job_class, *args) - Backburner::Worker.enqueue(job_class, args, {}) + def enqueue(job_class, *args, shard_key: nil) + Backburner::Worker.enqueue(job_class, args, { shard_key: shard_key.nil? ? "X" : shard_key.to_s }) end - def enqueue(job_class, args, shard_key = nil) - enqueue(job_class, args, { shard_key: shard_key.nil? ? "X" : shard_key.to_s }) - end # Begins working on jobs enqueued with optional tubes specified # # @example # Backburner.work('newsletter_sender', 'test_job') # Backburner.work('newsletter_sender', 'test_job', :worker => NotSimpleWorker)