Method: ActiveJob::QueueAdapters::BackburnerAdapter#enqueue
- Defined in:
- activejob/lib/active_job/queue_adapters/backburner_adapter.rb
#enqueue(job) ⇒ Object
:nodoc:
18 19 20 21 22 |
# File 'activejob/lib/active_job/queue_adapters/backburner_adapter.rb', line 18 def enqueue(job) # :nodoc: response = Backburner::Worker.enqueue(JobWrapper, [job.serialize], queue: job.queue_name, pri: job.priority) job.provider_job_id = response[:id] if response.is_a?(Hash) response end |