From e744cfee65c8efae19ec814a82895df2b3ff96b7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mehmet=20Emin=20=C4=B0NA=C3=87?= Date: Fri, 8 May 2015 16:45:04 +0300 Subject: Refactor sidekiq adapter enqueue and enqueue_at methods --- activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb | 8 ++------ 1 file 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: -- cgit v1.2.3