diff --git a/lib/shoryuken/fetcher.rb b/lib/shoryuken/fetcher.rb index fc9a3fc3..48b7d227 100644 --- a/lib/shoryuken/fetcher.rb +++ b/lib/shoryuken/fetcher.rb @@ -14,7 +14,7 @@ def fetch(queue, available_processors) limit = available_processors > FETCH_LIMIT ? FETCH_LIMIT : available_processors sqs_msgs = Array(receive_messages(queue, limit)) - logger.info { "Found #{sqs_msgs.size} messages for '#{queue}'" } + logger.info { "Found #{sqs_msgs.size} messages for '#{queue.name}'" } logger.debug { "Fetcher for '#{queue}' completed in #{elapsed(started_at)} ms" } sqs_msgs rescue => ex