diff --git a/lib/shoryuken/manager.rb b/lib/shoryuken/manager.rb index 87b5815b..2a38fdb2 100644 --- a/lib/shoryuken/manager.rb +++ b/lib/shoryuken/manager.rb @@ -104,12 +104,6 @@ def dispatch logger.debug { "Ready: #{@ready.size}, Busy: #{@busy.size}, Active Queues: #{polling_strategy.active_queues}" } - if @ready.empty? - logger.debug { 'Pausing fetcher, because all processors are busy' } - after(1) { dispatch } - return - end - queue = polling_strategy.next_queue if queue.nil? logger.debug { 'Pausing fetcher, because all queues are paused' }