From 12198f4d921eb6406d08a122e2e51971bf65e7fa Mon Sep 17 00:00:00 2001 From: xengineering Date: Sat, 20 Dec 2025 13:32:55 +0100 Subject: Log MQTT disconnect This makes connection loss visible during debugging. --- mqtt.go | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'mqtt.go') diff --git a/mqtt.go b/mqtt.go index 2fd4d13..1f935cf 100644 --- a/mqtt.go +++ b/mqtt.go @@ -29,6 +29,7 @@ func MQTTRun(tx chan MQTTMessage) { opts.SetClientID(CLIENT_ID) opts.SetCleanSession(true) opts.SetOnConnectHandler(MQTTOnConnectHandler) + opts.SetConnectionLostHandler(MQTTConnectionLostHandler) client := mqtt.NewClient(opts) @@ -49,3 +50,7 @@ func MQTTRun(tx chan MQTTMessage) { func MQTTOnConnectHandler(c mqtt.Client) { log.Printf("Connected to MQTT broker (%s)", BROKER) } + +func MQTTConnectionLostHandler(c mqtt.Client, err error) { + log.Printf("Connection to MQTT broker lost: %v", err) +} -- cgit v1.2.3-70-g09d2