diff --git a/lib/sidekiq/manager.rb b/lib/sidekiq/manager.rb index 9ca01736..031253f6 100644 --- a/lib/sidekiq/manager.rb +++ b/lib/sidekiq/manager.rb @@ -83,7 +83,7 @@ module Sidekiq if msg processor = @ready.pop @busy << processor - processor.process!(MultiJson.decode(msg), current_queue) + processor.process!(MultiJson.decode(msg), queue) end !!msg end