Include non-strict inequality for delivery tags

ruby-amqp · Jan 10, 2013 · 13dc862 · 13dc862
1 parent 4ca7986
commit 13dc862
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/bunny/channel.rb b/lib/bunny/channel.rb
@@ -711,7 +711,7 @@ def handle_basic_return(basic_return, properties, content)
 
     def handle_ack_or_nack(delivery_tag, multiple, nack)
       if multiple
-        @unconfirmed_set.delete_if { |i| i < delivery_tag }
+        @unconfirmed_set.delete_if { |i| i <= delivery_tag }
       else
         @unconfirmed_set.delete(delivery_tag)
       end