diff options
| author | David Heinemeier Hansson <david@basecamp.com> | 2014-05-19 13:43:03 +0200 |
|---|---|---|
| committer | David Heinemeier Hansson <david@basecamp.com> | 2014-05-19 13:43:03 +0200 |
| commit | a9dc36c8539c1ac9a5024d4b51369938893d581a (patch) | |
| tree | 6953fc0b626330a684d215ffe6ca14639d25a308 /lib/active_job | |
| parent | 70419b5ec3016eb5592a1fb57c2098b261e82998 (diff) | |
| parent | 62aa8acb13afb367f49a21b25c6ac416f5a7e09f (diff) | |
| download | rails-a9dc36c8539c1ac9a5024d4b51369938893d581a.tar.gz rails-a9dc36c8539c1ac9a5024d4b51369938893d581a.tar.bz2 rails-a9dc36c8539c1ac9a5024d4b51369938893d581a.zip | |
Merge pull request #22 from DouweM/patch-1
Have Sidekiq adapter take queue_name into account.
Diffstat (limited to 'lib/active_job')
| -rw-r--r-- | lib/active_job/queue_adapters/sidekiq_adapter.rb | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/active_job/queue_adapters/sidekiq_adapter.rb b/lib/active_job/queue_adapters/sidekiq_adapter.rb index 957905f9d3..e712762785 100644 --- a/lib/active_job/queue_adapters/sidekiq_adapter.rb +++ b/lib/active_job/queue_adapters/sidekiq_adapter.rb @@ -5,7 +5,7 @@ module ActiveJob class SidekiqAdapter class << self def queue(job, *args) - JobWrapper.perform_async(job, *args) + JobWrapper.client_push('class' => JobWrapper, 'queue' => job.queue_name, 'args' => [job, *args]) end end |