diff --git a/repeater/data_acquisition/mqtt_handler.py b/repeater/data_acquisition/mqtt_handler.py index a3672ff..87e9adb 100644 --- a/repeater/data_acquisition/mqtt_handler.py +++ b/repeater/data_acquisition/mqtt_handler.py @@ -285,6 +285,10 @@ class _BrokerConnection: def connect(self): """Establish connection to broker""" # Conditional TLS setup + if self.enabled == False: + logger.info(f"Connection to {self.broker['name']} is disabled in configuration") + return + if self.transport == "websockets": if self.tls and self.tls.get("enabled", True): import ssl