Troubleshoot duplicated consumers after reconnection

NeonGeckoCom · Feb 8, 2025 · c2a4e96 · c2a4e96
1 parent 1c56fbb
commit c2a4e96
Showing 1 changed file with 8 additions and 7 deletions.
diff --git 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: