diff --git a/lib/sidekiq/fetch.rb b/lib/sidekiq/fetch.rb index 2e3a787b..caa21629 100644 --- a/lib/sidekiq/fetch.rb +++ b/lib/sidekiq/fetch.rb @@ -41,13 +41,13 @@ module Sidekiq after(0) { fetch } end rescue => ex - handle_exception(ex) + handle_fetch_exception(ex) end end end - def handle_exception(ex) + def handle_fetch_exception(ex) if !@down logger.error("Error fetching message: #{ex}") ex.backtrace.each do |bt|