search

eandersson / amqpstorm

Thread-safe Python RabbitMQ Client & Management library
https://www.amqpstorm.io/
MIT License
186 stars 36 forks source link

Connection#check_for_errors doesn't account for IO#_inbound_thread being cleared #102

Closed galeng closed 3 years ago

galeng commented 3 years ago

I'm currently using version 2.8.4 and encountering an issue where my io._inbound_thread is is being cleared due to a connection reset -

amqpstorm.io WARNING amqpstorm.io: Stopping inbound thread due to [Errno 104] Connection reset by peer

I have a long-running connection and it is no longer processing any incoming data after it receives this warning. I don't see a way to recover from the error other than to periodically re-create my connection.

Any info would be appreciated.

galeng commented 3 years ago

NM, I see where it is checked.