diff --git a/gateway/include/mqtt.h b/gateway/include/mqtt.h index 65ee252..23ee529 100644 --- a/gateway/include/mqtt.h +++ b/gateway/include/mqtt.h @@ -55,10 +55,12 @@ namespace Mqtt { client.subscribe(mainTopic, 0); tReConnect.disable(); Serial.println("Connected to MQTT"); + turnLed(BLUE_LED, false); }); client.onDisconnect([](AsyncMqttClientDisconnectReason reason) { tReConnect.enableDelayed(); Serial.println("Disconnected from MQTT"); + turnLed(BLUE_LED); }); client.onMessage(onMessage); client.setServer(MQTT_HOST, MQTT_PORT);