diff options
| author | Kevin Deisz <kevin.deisz@gmail.com> | 2015-04-26 13:05:08 -0400 |
|---|---|---|
| committer | Kevin Deisz <kevin.deisz@gmail.com> | 2015-05-05 10:30:16 -0400 |
| commit | dd8e859829bfcfd8cb0287ce804055b827a35af1 (patch) | |
| tree | 71a31b6996d3b81766ff33eddf2f2d995b02d6b7 /activejob/lib/active_job/queue_adapters | |
| parent | 918aa6e87813c5c7687e5d460c5cd62ba3919536 (diff) | |
| download | rails-dd8e859829bfcfd8cb0287ce804055b827a35af1.tar.gz rails-dd8e859829bfcfd8cb0287ce804055b827a35af1.tar.bz2 rails-dd8e859829bfcfd8cb0287ce804055b827a35af1.zip | |
Get provider_job_id from DelayedJob
When queueing with DelayedJob, get the id of the job instance and report
it back to ActiveJob as provider_job_id.
Diffstat (limited to 'activejob/lib/active_job/queue_adapters')
| -rw-r--r-- | activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb b/activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb index 852a6ee326..ac83da2b9c 100644 --- a/activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb +++ b/activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb @@ -14,11 +14,15 @@ module ActiveJob # Rails.application.config.active_job.queue_adapter = :delayed_job class DelayedJobAdapter def enqueue(job) #:nodoc: - Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name) + delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name) + job.provider_job_id = delayed_job.id + delayed_job end def enqueue_at(job, timestamp) #:nodoc: - Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, run_at: Time.at(timestamp)) + delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, run_at: Time.at(timestamp)) + job.provider_job_id = delayed_job.id + delayed_job end class JobWrapper #:nodoc: |