From c2a4e9635dfc2533d658cea23105fc9e7fe1d465 Mon Sep 17 00:00:00 2001 From: Daniel McKnight Date: Fri, 7 Feb 2025 18:07:58 -0800 Subject: [PATCH] Troubleshoot duplicated consumers after reconnection --- neon_mq_connector/consumers/select_consumer.py | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/neon_mq_connector/consumers/select_consumer.py b/neon_mq_connector/consumers/select_consumer.py index 6de76da..70e899d 100644 --- a/neon_mq_connector/consumers/select_consumer.py +++ b/neon_mq_connector/consumers/select_consumer.py @@ -206,13 +206,14 @@ def on_close(self, _, e): else: LOG.error(f"MQ connection closed due to exception: {e}") if not self._stopping: - if e.reply_code == 320: - LOG.info(f"Server shutdown. Try to reconnect after 60s (t={self.name})") - self.reconnect(60) - else: - # Connection was lost or closed by the server. Try to re-connect - LOG.info(f"Trying to reconnect after server connection loss") - self.reconnect() + LOG.info("Consumer is not stopping. It will reconnect to the server when it becomes available") + # if e.reply_code == 320: + # LOG.info(f"Server shutdown. Try to reconnect after 60s (t={self.name})") + # self.reconnect(60) + # else: + # # Connection was lost or closed by the server. Try to re-connect + # LOG.info(f"Trying to reconnect after server connection loss") + # self.reconnect() @property def is_consumer_alive(self) -> bool: