diff options
| author | Mehmet Emin İNAÇ <mehmetemininac@gmail.com> | 2015-05-08 16:45:04 +0300 |
|---|---|---|
| committer | Mehmet Emin İNAÇ <mehmetemininac@gmail.com> | 2015-05-08 16:45:04 +0300 |
| commit | e744cfee65c8efae19ec814a82895df2b3ff96b7 (patch) | |
| tree | aa20166abbdfd720cf68c75e7b929cc233934dd7 | |
| parent | 0834d60d64a159765a2719eedbf1518334f86644 (diff) | |
| download | rails-e744cfee65c8efae19ec814a82895df2b3ff96b7.tar.gz rails-e744cfee65c8efae19ec814a82895df2b3ff96b7.tar.bz2 rails-e744cfee65c8efae19ec814a82895df2b3ff96b7.zip | |
Refactor sidekiq adapter enqueue and enqueue_at methods
| -rw-r--r-- | activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb b/activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb index 7a2dd3e9fc..c321776bf5 100644 --- a/activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb +++ b/activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb @@ -17,24 +17,20 @@ module ActiveJob class SidekiqAdapter def enqueue(job) #:nodoc: #Sidekiq::Client does not support symbols as keys - sidekiq_job_id = Sidekiq::Client.push \ + job.provider_job_id = Sidekiq::Client.push \ 'class' => JobWrapper, 'wrapped' => job.class.to_s, 'queue' => job.queue_name, 'args' => [ job.serialize ] - job.provider_job_id = sidekiq_job_id - sidekiq_job_id end def enqueue_at(job, timestamp) #:nodoc: - sidekiq_job_id = Sidekiq::Client.push \ + job.provider_job_id = Sidekiq::Client.push \ 'class' => JobWrapper, 'wrapped' => job.class.to_s, 'queue' => job.queue_name, 'args' => [ job.serialize ], 'at' => timestamp - job.provider_job_id = sidekiq_job_id - sidekiq_job_id end class JobWrapper #:nodoc: |