diff --git a/dayglo_detector/dayglo_detector.py b/dayglo_detector/dayglo_detector.py index e1f6290..3d85171 100644 --- a/dayglo_detector/dayglo_detector.py +++ b/dayglo_detector/dayglo_detector.py @@ -32,13 +32,13 @@ initial_snapshot_processed = False def on_connect(client, userdata, flags, reasonCode, properties=None): try: if reasonCode == 0: - print("Connected successfully to MQTT broker") - client.subscribe(MQTT_SNAPSHOT_TOPIC, qos=1) - print(f"Subscribed to topic: {MQTT_SNAPSHOT_TOPIC}") - publish_discovery_configurations() - # Publish initial rating of 0 - publish_rating(0) - else: + print("Connected successfully to MQTT broker") + client.subscribe(MQTT_SNAPSHOT_TOPIC, qos=1) + print(f"Subscribed to topic: {MQTT_SNAPSHOT_TOPIC}") + publish_discovery_configurations() + # Publish initial rating of 0 + publish_rating(0) + else: print(f"Failed to connect, return code {reasonCode}") except Exception as e: print(f"Caught exception in on_connect: {e}")