You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
librabbitmq-c version: 0.10.0
rabbitmq-server version: 3.9.13
OS: Ubuntu 22.04
I'm using the standard Ubuntu packages for librabbitmq-dev and rabbitmq-server.
Description
If the broker is in a connection.blocked state (as described here, calls to amqp_queue_declare() will cause the calling program to hang indefinitely.
I think that the call to amqp_queue_declare() should instead return and set a suitable RPC reply type that would allow the caller to see that the declaration failed due to the broker being blocked.
I've tried calling amqp_simple_wait_frame_noblock() before attempting to declare the queue to try and catch the AMQP_CONNECTION_BLOCKED_METHOD method in the hope that would be an indication that the broker is blocked, but amqp_simple_wait_frame_noblock() only returns AMQP_STATUS_TIMEOUT. I'm assuming that this means AMQP_CONNECTION_BLOCKED_METHOD is only going to be generated in response to a publish attempt?
Is there any other way that I could try to detect that the connection is blocked before calling amqp_queue_declare() ?
The text was updated successfully, but these errors were encountered:
System details
librabbitmq-c version: 0.10.0
rabbitmq-server version: 3.9.13
OS: Ubuntu 22.04
I'm using the standard Ubuntu packages for librabbitmq-dev and rabbitmq-server.
Description
If the broker is in a
connection.blocked
state (as described here, calls toamqp_queue_declare()
will cause the calling program to hang indefinitely.I think that the call to
amqp_queue_declare()
should instead return and set a suitable RPC reply type that would allow the caller to see that the declaration failed due to the broker being blocked.I've tried calling
amqp_simple_wait_frame_noblock()
before attempting to declare the queue to try and catch theAMQP_CONNECTION_BLOCKED_METHOD
method in the hope that would be an indication that the broker is blocked, butamqp_simple_wait_frame_noblock()
only returnsAMQP_STATUS_TIMEOUT
. I'm assuming that this means AMQP_CONNECTION_BLOCKED_METHOD is only going to be generated in response to a publish attempt?Is there any other way that I could try to detect that the connection is blocked before calling
amqp_queue_declare()
?The text was updated successfully, but these errors were encountered: