Introduce dispatch callback

ruby-shoryuken · Apr 27, 2017 · c0bdff3 · c0bdff3
1 parent 2ffe7a5
commit c0bdff3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/lib/shoryuken.rb b/lib/shoryuken.rb
@@ -35,6 +35,7 @@ module Shoryuken
     timeout: 8,
     lifecycle_events: {
       startup: [],
+      dispatch: [],
       quiet: [],
       shutdown: []
     },

diff --git a/lib/shoryuken/manager.rb b/lib/shoryuken/manager.rb
@@ -73,6 +73,8 @@ def dispatch_now
           return
         end
 
+        fire_event(:dispatch, false)
+
         logger.debug { "Ready: #{ready}, Busy: #{busy}, Active Queues: #{@polling_strategy.active_queues}" }
 
         batched_queue?(queue) ? dispatch_batch(queue) : dispatch_single_messages(queue)
-Original file line number
+Diff line change
@@ Expand Up / @@ -73,6 +73,8 @@ def dispatch_now @@
               return
             end
+            fire_event(:dispatch, false)
             logger.debug { "Ready: #{ready}, Busy: #{busy}, Active Queues: #{@polling_strategy.active_queues}" }
             batched_queue?(queue) ? dispatch_batch(queue) : dispatch_single_messages(queue)
@@ Expand Down @@