diff --git a/lib/shoryuken.rb b/lib/shoryuken.rb index 72266149..90c990bc 100644 --- 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 index b1055124..ac89c8ad 100644 --- 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)