diff options
| author | Douwe Maan <douwe@selenight.nl> | 2014-05-19 13:36:08 +0200 |
|---|---|---|
| committer | Douwe Maan <douwe@selenight.nl> | 2014-05-19 13:36:08 +0200 |
| commit | 62aa8acb13afb367f49a21b25c6ac416f5a7e09f (patch) | |
| tree | 6953fc0b626330a684d215ffe6ca14639d25a308 | |
| parent | 70419b5ec3016eb5592a1fb57c2098b261e82998 (diff) | |
| download | rails-62aa8acb13afb367f49a21b25c6ac416f5a7e09f.tar.gz rails-62aa8acb13afb367f49a21b25c6ac416f5a7e09f.tar.bz2 rails-62aa8acb13afb367f49a21b25c6ac416f5a7e09f.zip | |
Have Sidekiq adapter take queue_name into account.
| -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 |