From c2c20672822ed202e5f87daf807c3b1ad68a5322 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Carl=20H=C3=B6rberg?= Date: Mon, 25 Mar 2024 08:42:21 +0100 Subject: [PATCH] fix --- lib/amqp/client/channel.rb | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/lib/amqp/client/channel.rb b/lib/amqp/client/channel.rb index 918d66c..1e31187 100644 --- 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