From 62aa8acb13afb367f49a21b25c6ac416f5a7e09f Mon Sep 17 00:00:00 2001
From: Douwe Maan <douwe@selenight.nl>
Date: Mon, 19 May 2014 13:36:08 +0200
Subject: Have Sidekiq adapter take queue_name into account.
---
lib/active_job/queue_adapters/sidekiq_adapter.rb | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
(limited to 'lib/active_job')
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
--
cgit v1.2.3