Log MQTT disconnect

This makes connection loss visible during debugging.

1 files changed, 5 insertions, 0 deletions

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)
+}