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 = {})