try to reconnect when connection fails.

MetPX · Oct 19, 2023 · 2a94d05 · 2a94d05
1 parent f761fe9
commit 2a94d05
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/sarracenia/flowcb/gather/message.py b/sarracenia/flowcb/gather/message.py
@@ -31,10 +31,7 @@ def gather(self) -> list:
         """
            return a current list of messages.
         """
-        if not hasattr(self,'consumer'):
-            return []
-
-        if hasattr(self.consumer,'newMessages'):
+        if hasattr(self,'consumer') and hasattr(self.consumer,'newMessages'):
             return self.consumer.newMessages()
         else:
             logger.warning( f'not connected. Trying to connect to {self.o.broker}')