From 54cf408e1f5706a085ed87f261dae2ba2b8448f1 Mon Sep 17 00:00:00 2001 From: Ernest Surudo Date: Thu, 6 Nov 2014 09:32:50 +0100 Subject: [PATCH 1/2] Log queue status messages to debug, not info loglevel --- lib/shoryuken/fetcher.rb | 4 ++-- lib/shoryuken/manager.rb | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/shoryuken/fetcher.rb b/lib/shoryuken/fetcher.rb index 7e296fd3..d9be6116 100644 --- a/lib/shoryuken/fetcher.rb +++ b/lib/shoryuken/fetcher.rb @@ -20,7 +20,7 @@ def fetch(queue, available_processors) watchdog('Fetcher#fetch died') do started_at = Time.now - logger.info "Looking for new messages '#{queue}'" + logger.debug "Looking for new messages '#{queue}'" begin batch = !!Shoryuken.workers[queue].get_shoryuken_options['batch'] @@ -38,7 +38,7 @@ def fetch(queue, available_processors) @manager.async.rebalance_queue_weight!(queue) else - logger.info "No message found for '#{queue}'" + logger.debug "No message found for '#{queue}'" @manager.async.pause_queue!(queue) end diff --git a/lib/shoryuken/manager.rb b/lib/shoryuken/manager.rb index 14464cc6..2443e233 100644 --- a/lib/shoryuken/manager.rb +++ b/lib/shoryuken/manager.rb @@ -103,7 +103,7 @@ def rebalance_queue_weight!(queue) def pause_queue!(queue) return if !@queues.include?(queue) || Shoryuken.options[:delay].to_f <= 0 - logger.info "Pausing '#{queue}' for #{Shoryuken.options[:delay].to_f} seconds, because it's empty" + logger.debug "Pausing '#{queue}' for #{Shoryuken.options[:delay].to_f} seconds, because it's empty" @queues.delete(queue) @@ -139,7 +139,7 @@ def restart_queue!(queue) return if stopped? unless @queues.include? queue - logger.info "Restarting '#{queue}'" + logger.debug "Restarting '#{queue}'" @queues << queue From bb99fd22512da541f5e1fe0cc51c0af0f8661eda Mon Sep 17 00:00:00 2001 From: Ernest Surudo Date: Fri, 7 Nov 2014 11:06:09 +0100 Subject: [PATCH 2/2] Added extra word. --- lib/shoryuken/fetcher.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/shoryuken/fetcher.rb b/lib/shoryuken/fetcher.rb index d9be6116..80373cd7 100644 --- a/lib/shoryuken/fetcher.rb +++ b/lib/shoryuken/fetcher.rb @@ -20,7 +20,7 @@ def fetch(queue, available_processors) watchdog('Fetcher#fetch died') do started_at = Time.now - logger.debug "Looking for new messages '#{queue}'" + logger.debug "Looking for new messages in '#{queue}'" begin batch = !!Shoryuken.workers[queue].get_shoryuken_options['batch']