lib/bunny/channel.rb in bunny-0.9.0.pre11 vs lib/bunny/channel.rb in bunny-0.9.0.pre12

@@ -1307,10 +1307,11 @@
     # @see #unconfirmed_set
     # @see #nacked_set
     # @see http://rubybunny.info/articles/extensions.html RabbitMQ Extensions guide
     # @api public
     def wait_for_confirms
+      @only_acks_received = true
       wait_on_confirms_continuations
 
       @only_acks_received
     end
 
@@ -1560,9 +1561,10 @@
         @unconfirmed_set.delete(delivery_tag)
       end
 
       @unconfirmed_set_mutex.synchronize do
         @only_acks_received = (@only_acks_received && !nack)
+        @logger.debug "Channel #{@id}: @only_acks_received = #{@only_acks_received.inspect}, nack: #{nack.inspect}"
 
         @confirms_continuations.push(true) if @unconfirmed_set.empty?
 
         @confirms_callback.call(delivery_tag, multiple, nack) if @confirms_callback
       end