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

- old
+ new

@@ -27,9 +27,12 @@ # def enqueue(job_class, *args) Backburner::Worker.enqueue(job_class, args, {}) 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)