lib/bunny/channel.rb in bunny-2.18.0 vs lib/bunny/channel.rb in bunny-2.19.0
- old
+ new
@@ -1787,10 +1787,10 @@
end
# @private
def handle_ack_or_nack(delivery_tag_before_offset, multiple, nack)
delivery_tag = delivery_tag_before_offset + @delivery_tag_offset
- confirmed_range_start = multiple ? @delivery_tag_offset + 1 : delivery_tag
+ confirmed_range_start = multiple ? @delivery_tag_offset + @unconfirmed_set.min : delivery_tag
confirmed_range_end = delivery_tag
confirmed_range = (confirmed_range_start..confirmed_range_end)
@unconfirmed_set_mutex.synchronize do
if nack