Merge pull request #147 from bobbrez/bobbrez/allow_queue_option

Enable override the default queue with a :queue option

lib/shoryuken/worker.rb

@@ -6,7 +6,6 @@ def self.included(base)
 
     module ClassMethods
       def perform_async(body, options = {})
-        options ||= {}
         options[:message_attributes] ||= {}
         options[:message_attributes]['shoryuken_class'] = {
           string_value: self.to_s,
@@ -15,7 +14,9 @@ def perform_async(body, options = {})
 
         options[:message_body] = body
 
-        Shoryuken::Client.queues(get_shoryuken_options['queue']).send_message(options)
+        queue = options.delete(:queue) || get_shoryuken_options['queue']
+
+        Shoryuken::Client.queues(queue).send_message(options)
       end
 
       def perform_in(interval, body, options = {})

spec/shoryuken/worker_spec.rb

@@ -79,6 +79,23 @@
 
       TestWorker.perform_async('delayed message', delay_seconds: 60)
     end
+
+    it 'accepts an `queue` option' do
+      new_queue = 'some_different_queue'
+
+      expect(Shoryuken::Client).to receive(:queues).with(new_queue).and_return(sqs_queue)
+
+      expect(sqs_queue).to receive(:send_message).with(
+        message_attributes: {
+          'shoryuken_class' => {
+            string_value: TestWorker.to_s,
+            data_type: 'String'
+          }
+        },
+        message_body: 'delayed message')
+
+      TestWorker.perform_async('delayed message', queue: new_queue)
+    end
   end
 
   describe '.shoryuken_options' do