Skip to content

Commit

Permalink
expect Exchange::UnbindOk when unbinding exchange
Browse files Browse the repository at this point in the history
  • Loading branch information
snichme committed Oct 8, 2024
1 parent 1280e20 commit 3f78e4d
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/amqp-client/channel.cr
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 3f78e4d

Please sign in to comment.