Issue recreating connection to a queue after a connection problem

[dd185209]

Hi my application is using aio-pika=9.4.1 to connect to a rabbitmq. I'm testing under docker environment and if I manually shutdown rabbit I see following log messages:

Unexpected connection close from remote "amqp://user:******@localhost:5672", Connection.Close(reply_code=320, reply_text="CONNECTION_FORCED - broker forced connection closure with reason 'shutdown'")
NoneType: None
Connection attempt to "amqp://user:******@localhost" failed: Server connection unexpectedly closed. Read 0 bytes but 1 bytes expected. Reconnecting after 5 seconds.
Connection attempt to "amqp://user:******@localhost" failed: [WinError 1225] The remote computer refused the network connection. Reconnecting after 5 seconds.
Connection attempt to "amqp://user:******@localhost" failed: [WinError 1225] The remote computer refused the network connection. Reconnecting after 5 seconds.
Connection attempt to "amqp://user:******@localhost" failed: [WinError 1225] The remote computer refused the network connection. Reconnecting after 5 seconds.

but when rabbit restarts I see following errors:

Connection attempt to "amqp://user:******@localhost" failed: Server connection unexpectedly closed. Read 0 bytes but 1 bytes expected. Reconnecting after 5 seconds.
Connection attempt to "amqp://user:******@localhost" failed: Server connection unexpectedly closed. Read 0 bytes but 1 bytes expected. Reconnecting after 5 seconds.

then the application is successfully connecting to new instance (no more error where logged) but it's not true for the exchange and queue (there is no consumer).
The application is now blocked whiting for new messages that never be read.

Using aio-pika==8.2.1 the application were working fine, I got similar error when the rabbitmq is down, but when it comes up again even the consumer is connected and messages are processed correctly.

[Darsstar]

This could be a duplicate of #594.

How certain are you that there is a strong reference chain to the Channel or Queue?

[drsnyder]

Also confirmed that 9.4.1 does not reconnect after a rabbit restart but 8.2.1 does. In my testing, the application gets blocked on this line waiting for the __connection_close_event to be set.

[mosquito]

@drsnyder did you try to upgrade to the latest release?

[drsnyder]

Yes, I tried upgrading. Release 9.4.2 also does not work.

[mosquito]

Current version is https://pypi.org/project/aio-pika/9.5.4/

[drsnyder]

@mosquito, thanks for getting back to me so fast. Sorry, 9.5.4 doesn't work either. It appears to be reconnecting but the consumer call backs are not receiving messages. Similar to the OP, I get:

Unexpected connection close from remote "amqp://<user>:******@localhost:5672//?reconnect_interval=10&fail_fast=0", Connection.Close(reply_code=320, reply_text="CONNECTION_FORCED - broker forced connection closure with reason 'shutdown'")
NoneType: None
Connection attempt to "amqp://<user>:******@localhost:5672//?reconnect_interval=10&fail_fast=0" failed: Server connection unexpectedly closed. Read 0 bytes but 1 bytes expected. Reconnecting after 10 seconds.
Connection attempt to "amqp://<user>:******@localhost:5672//?reconnect_interval=10&fail_fast=0" failed: Server connection unexpectedly closed. Read 0 bytes but 1 bytes expected. Reconnecting after 10 seconds.
Connection attempt to "amqp://<user>:******@localhost:5672//?reconnect_interval=10&fail_fast=0" failed: Server connection unexpectedly closed. Read 0 bytes but 1 bytes expected. Reconnecting after 10 seconds.
Connection attempt to "amqp://<user>:******@localhost:5672//?reconnect_interval=10&fail_fast=0" failed: Server connection unexpectedly closed. Read 0 bytes but 1 bytes expected. Reconnecting after 10 seconds.