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)