Merge pull request #362 from Erol/introduce-dispatch-callback

Introduce dispatch event

lib/shoryuken.rb

@@ -35,6 +35,7 @@ module Shoryuken
     timeout: 8,
     lifecycle_events: {
       startup: [],
+      dispatch: [],
       quiet: [],
       shutdown: []
     },

lib/shoryuken/manager.rb

@@ -73,6 +73,8 @@ def dispatch_now
           return
         end
 
+        fire_event(:dispatch)
+
         logger.debug { "Ready: #{ready}, Busy: #{busy}, Active Queues: #{@polling_strategy.active_queues}" }
 
         batched_queue?(queue) ? dispatch_batch(queue) : dispatch_single_messages(queue)

spec/shoryuken/manager_spec.rb

@@ -55,6 +55,13 @@
     end
   end
 
+  describe '#dispatch_now' do
+    it 'fires a dispatch event' do
+      expect(subject).to receive(:fire_event).with(:dispatch).once
+      subject.send(:dispatch_now)
+    end
+  end
+
   describe '#dispatch_batch' do
     it 'assings batch as a single message' do
       q = polling_strategy.next_queue