fix

cloudamqp · Mar 25, 2024 · c2c2067 · c2c2067
1 parent 7b71150
commit c2c2067
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/amqp/client/channel.rb b/lib/amqp/client/channel.rb
@@ -437,7 +437,11 @@ def confirm(args)
 
           ok = ack_or_nack == :ack
           until @unconfirmed_empty.num_waiting.zero?
-            @unconfirmed_empty.push(ok, timeout: 0.001) || break
+            begin
+              @unconfirmed_empty.push(ok, timeout: 0.001)
+            rescue ThreadError
+              next
+            end
           end
           @unconfirmed_empty.pop(timeout: 0) # don't leave a residual ok in the queue
         end