Merge branch 'elsurudo-logging'; Fix #9

ruby-shoryuken · Nov 7, 2014 · a9ffdc9 · a9ffdc9
2 parents c42335c + bb99fd2
commit a9ffdc9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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 in '#{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
@@ -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