Don't crash if no internet connection
This commit is contained in:
@@ -106,9 +106,12 @@ cloud_mqtt_client = get_mqtt_client(
|
|||||||
password="myMicrowaveVerySecret",
|
password="myMicrowaveVerySecret",
|
||||||
keepalive=config.MQTT_KEEPALIVE,
|
keepalive=config.MQTT_KEEPALIVE,
|
||||||
)
|
)
|
||||||
cloud_mqtt_client.connect()
|
try:
|
||||||
cloud_mqtt_client.subscribe("cmd/all", qos=config.CLOUD_MQTT_QOS)
|
cloud_mqtt_client.connect()
|
||||||
cloud_mqtt_client.subscribe(f"cmd/{DEVICE_ID}", qos=config.CLOUD_MQTT_QOS)
|
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"):
|
if hasattr(cloud_mqtt_client._client, "loop_start"):
|
||||||
cloud_mqtt_client._client.loop_start()
|
cloud_mqtt_client._client.loop_start()
|
||||||
|
|||||||
Reference in New Issue
Block a user