lib/bunny/channel.rb in bunny-0.9.0.rc1 vs lib/bunny/channel.rb in bunny-0.9.0.rc2
- old
+ new
@@ -1688,20 +1688,24 @@
# Starts consumer work pool. Lazily called by #basic_consume to avoid creating new threads
# that won't do any real work for channels that do not register consumers (e.g. only used for
# publishing). MK.
# @private
def maybe_start_consumer_work_pool!
- @work_pool.start unless @work_pool.started?
+ if @work_pool && !@work_pool.running?
+ @work_pool.start
+ end
end
# @private
def maybe_pause_consumer_work_pool!
- @work_pool.pause if @work_pool && @work_pool.started?
+ @work_pool.pause if @work_pool && @work_pool.running?
end
# @private
def maybe_kill_consumer_work_pool!
- @work_pool.kill if @work_pool && @work_pool.started?
+ if @work_pool && @work_pool.running?
+ @work_pool.kill
+ end
end
# @private
def read_next_frame(options = {})
@connection.read_next_frame(options = {})