more error recovery for bad broker credentials #784

MetPX · Oct 19, 2023 · faf6b42 · faf6b42
1 parent 2a94d05
commit faf6b42
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/sarracenia/flowcb/gather/message.py b/sarracenia/flowcb/gather/message.py
@@ -20,9 +20,10 @@ def __init__(self, options) -> None:
 
         super().__init__(options,logger)
 
+        self.od = sarracenia.moth.default_options
+        self.od.update(self.o.dictify())
+
         if hasattr(self.o, 'broker') and self.o.broker:
-            self.od = sarracenia.moth.default_options
-            self.od.update(self.o.dictify())
             self.consumer = sarracenia.moth.Moth.subFactory(self.od)
         else:
             logger.critical('missing required broker specification')