RecoverableConnectionError: connection already closed

[zyong]

I found a RecoverableConnectionError exceptions while calling on_message, and connecting retry forever, I paste part of log. Could you help me to solve these problem?

macos 12.6
python 3.9

kombu==5.2.4
amqp==5.2.0

[INFO]:2023-11-15 19:24:16,075 - mixins.py:225-[59891:MainThread]> Connected to amqp://guest:**@192.168.1.171:5673// [WARNING]:2023-11-15 19:44:03,370 - mixins.py:176-[59891:MainThread]> Connection to broker lost, trying to re-establish connection... Traceback (most recent call last): File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/mixins.py", line 171, in run for _ in self.consume(limit=None, **kwargs): File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/mixins.py", line 187, in consume with self.consumer_context(**kwargs) as (conn, channel, consumers): File "/Users/yong/homebrew/Cellar/python@3.9/3.9.13_1/Frameworks/Python.framework/Versions/3.9/lib/python3.9/contextlib.py", line 119, in __enter__ return next(self.gen) File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/mixins.py", line 180, in consumer_context with self.Consumer() as (connection, channel, consumers): File "/Users/yong/homebrew/Cellar/python@3.9/3.9.13_1/Frameworks/Python.framework/Versions/3.9/lib/python3.9/contextlib.py", line 119, in __enter__ return next(self.gen) File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/mixins.py", line 229, in Consumer with self._consume_from(*self.get_consumers(cls, channel)) as c: File "/Users/yong/homebrew/Cellar/python@3.9/3.9.13_1/Frameworks/Python.framework/Versions/3.9/lib/python3.9/contextlib.py", line 119, in __enter__ return next(self.gen) File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/utils/compat.py", line 130, in nested reraise(exc[0], exc[1], exc[2]) File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/exceptions.py", line 22, in reraise raise value File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/utils/compat.py", line 113, in nested vars.append(enter()) File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/messaging.py", line 435, in __enter__ self.consume() File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/messaging.py", line 478, in consume self._basic_consume(T, no_ack=no_ack, nowait=False) File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/messaging.py", line 599, in _basic_consume queue.consume(tag, self._receive_callback, File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/kombu/entity.py", line 732, in consume return self.channel.basic_consume( File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/amqp/channel.py", line 1574, in basic_consume p = self.send_method( File "/Users/yong/Develop/python/street_view_automation/venv/lib/python3.9/site-packages/amqp/abstract_channel.py", line 67, in send_method raise RecoverableConnectionError('connection already closed') amqp.exceptions.RecoverableConnectionError: connection already closed