Skip to content

Commit

Permalink
unconfirmed empty queue might have no waiting
Browse files Browse the repository at this point in the history
  • Loading branch information
carlhoerberg committed Mar 24, 2024
1 parent 4ef6984 commit e1af09c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion lib/amqp/client/channel.rb
Original file line number Diff line number Diff line change
Expand Up @@ -431,7 +431,7 @@ def confirm(args)

ok = ack_or_nack == :ack
@unconfirmed_empty.push(ok) until @unconfirmed_empty.num_waiting.zero?
@unconfirmed_empty.pop # don't leave a residual ok in the queue
@unconfirmed_empty.pop if @unconfirmed_empty.length > 0 # don't leave a residual ok in the queue
end

# @!endgroup
Expand Down

0 comments on commit e1af09c

Please sign in to comment.