diff --git a/repeater/data_acquisition/mqtt_handler.py b/repeater/data_acquisition/mqtt_handler.py index b9df014..e0b0117 100644 --- a/repeater/data_acquisition/mqtt_handler.py +++ b/repeater/data_acquisition/mqtt_handler.py @@ -801,6 +801,8 @@ class MeshCoreToMqttPusher: result = conn.publish(subtopic, message, retain=retain, qos=qos) results.append((conn.broker["name"], result)) logger.debug(f"Published to {conn.broker['name']} -- {subtopic}") + elif conn.enabled == False: + results.append((conn.broker["name"], "Skipped due to being disabled")) # Indicate skipped due to format mismatch if not results: logger.warning(f"No active broker connections for publishing to {subtopic}") @@ -826,6 +828,8 @@ class MeshCoreToMqttPusher: result = conn.publish(subtopic, message, retain=retain, qos=qos) results.append((conn.broker["name"], result)) logger.debug(f"Published to {conn.broker['name']} -- {subtopic}") + elif conn.enabled == False: + results.append((conn.broker["name"], "Skipped due to being disabled")) # Indicate skipped due to format mismatch if not results: logger.warning(f"No active broker connections for publishing to {subtopic}")