lib/bunny/channel.rb in bunny-2.6.0 vs lib/bunny/channel.rb in bunny-2.6.1
- old
+ new
@@ -950,10 +950,12 @@
Bunny::Timeout.timeout(wait_on_continuations_timeout, ClientTimeout) do
@last_basic_cancel_ok = wait_on_continuations
end
- @work_pool.shutdown(true) unless any_consumers?
+ # reduces thread usage for channels that don't have any
+ # consumers
+ @work_pool.shutdown(true) unless self.any_consumers?
@last_basic_cancel_ok
end
# @return [Boolean] true if there are consumers on this channel