TEST_CODEOWNERS/rails
3
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #20072 from vngrs/refactor_active_job_sidekiq_adapter

Browse Source 
Refactor sidekiq adapter enqueue and enqueue_at methods
This commit is contained in:
Yves Senn 2015-05-08 16:29:04 +02:00
commit 0b305bfe1a
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb
View File

@ -17,24 +17,20 @@ module QueueAdapters
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: