lib/sidekiq/throttled/queues_pauser.rb in sidekiq-throttled-0.7.3 vs lib/sidekiq/throttled/queues_pauser.rb in sidekiq-throttled-0.8.0
- old
+ new
@@ -56,10 +56,10 @@
@communicator.receive RESUME_MESSAGE do |queue|
@paused_queues.delete QueueName.expand(queue)
end
@communicator.ready do
- @paused_queues.replace paused_queues.map { |q| QueueName.expand q }
+ @paused_queues.replace(paused_queues.map { |q| QueueName.expand q })
end
end
end
# Returns queues list with paused queues being stripped out.