Reconnect if ioloop fails to get started

NeonGeckoCom · Jan 2, 2025 · ea50901 · ea50901
1 parent f845c3f
commit ea50901
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/neon_mq_connector/consumers/select_consumer.py b/neon_mq_connector/consumers/select_consumer.py
@@ -207,8 +207,8 @@ def run(self):
                 self.connection: pika.SelectConnection = self.create_connection()
                 self.connection.ioloop.start()
             except Exception as e:
-                LOG.error(f"Failed to start io loop on consumer thread {self.name!r}: {e}")
-                self._close_connection()
+                LOG.error(f"Failed to start io loop on consumer thread {self.name!r}: {e}, reconnecting")
+                self.reconnect()
 
     def _close_connection(self, mark_consumer_as_dead: bool = True):
         try: