From 3f78e4dc886d8a191489939150fdca5c6093e8c2 Mon Sep 17 00:00:00 2001 From: Magnus Landerblom Date: Tue, 8 Oct 2024 12:58:44 +0200 Subject: [PATCH] expect Exchange::UnbindOk when unbinding exchange --- src/amqp-client/channel.cr | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/amqp-client/channel.cr b/src/amqp-client/channel.cr index 061c05e..e3f3ab9 100644 --- a/src/amqp-client/channel.cr +++ b/src/amqp-client/channel.cr @@ -619,7 +619,7 @@ class AMQP::Client # Unbind an exchange from another exchange def exchange_unbind(source : String, destination : String, routing_key : String, no_wait = false, args arguments = Arguments.new) : Nil write Frame::Exchange::Unbind.new(@id, 0_u16, source, destination, routing_key, no_wait, arguments) - expect Frame::Queue::UnbindOk unless no_wait + expect Frame::Exchange::UnbindOk unless no_wait end # Sets the channel in publish confirm mode, each published message will be acked or nacked