reconnect logic

Signed-off-by: Clemens Vasters <clemens@vasters.com>

Author: clemensv

mode-s/mode_s_kafka_bridge/mode_s.py

@@ -48,6 +48,14 @@ def stop(self):
         self.stop_flag = True
         return super().stop()
 
+    def run(self, raw_pipe_in=None, stop_flag=None, exception_queue=None):
+        while not self.stop_flag:
+            try:
+                super().run(raw_pipe_in=raw_pipe_in, stop_flag=stop_flag, exception_queue=exception_queue)
+            except Exception as e:
+                logger.error("Error in run loop: %s", e)
+                time.sleep(1)
+    
     def handle_messages(self, messages):
         try:
             if self.stop_flag: