spec/shoryuken/manager_spec.rb in shoryuken-3.1.8 vs spec/shoryuken/manager_spec.rb in shoryuken-3.1.9

@@ -68,11 +68,11 @@
       message  = ['test1']
       messages = [message]
       q = Shoryuken::Polling::QueueConfiguration.new(queue, {})
 
       expect(fetcher).to receive(:fetch).with(q, concurrency).and_return(messages)
-      expect(subject).to receive(:fire_event).with(:dispatch)
+      expect(subject).to receive(:fire_event).with(:dispatch, false, queue_name: q.name)
       expect(Shoryuken::Processor).to receive(:process).with(q, message)
       expect(Shoryuken.logger).to_not receive(:info)
 
       subject.send(:dispatch)
     end
@@ -81,10 +81,10 @@
       specify do
         messages = %w(test1 test2 test3)
         q = Shoryuken::Polling::QueueConfiguration.new(queue, {})
 
         expect(fetcher).to receive(:fetch).with(q, described_class::BATCH_LIMIT).and_return(messages)
-        expect(subject).to receive(:fire_event).with(:dispatch)
+        expect(subject).to receive(:fire_event).with(:dispatch, false, queue_name: q.name)
         allow(subject).to receive(:batched_queue?).with(q).and_return(true)
         expect(Shoryuken::Processor).to receive(:process).with(q, messages)
         expect(Shoryuken.logger).to_not receive(:info)
 
         subject.send(:dispatch)