diff --git a/orchestrateur/main.py b/orchestrateur/main.py index 8cce822..4dd84cd 100644 --- a/orchestrateur/main.py +++ b/orchestrateur/main.py @@ -106,9 +106,12 @@ cloud_mqtt_client = get_mqtt_client( password="myMicrowaveVerySecret", keepalive=config.MQTT_KEEPALIVE, ) -cloud_mqtt_client.connect() -cloud_mqtt_client.subscribe("cmd/all", qos=config.CLOUD_MQTT_QOS) -cloud_mqtt_client.subscribe(f"cmd/{DEVICE_ID}", qos=config.CLOUD_MQTT_QOS) +try: + cloud_mqtt_client.connect() + cloud_mqtt_client.subscribe("cmd/all", qos=config.CLOUD_MQTT_QOS) + cloud_mqtt_client.subscribe(f"cmd/{DEVICE_ID}", qos=config.CLOUD_MQTT_QOS) +except Exception as e: + print(f"[MQTT Cloud] Error connecting to cloud MQTT broker: {e}") if hasattr(cloud_mqtt_client._client, "loop_start"): cloud_mqtt_client._client.loop_start()