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)