diff --git a/src/mqtt/mqtt.go b/src/mqtt/mqtt.go index c670b92..12d8971 100644 --- a/src/mqtt/mqtt.go +++ b/src/mqtt/mqtt.go @@ -57,6 +57,7 @@ func Setup() { syslog.Err("mqtt connection lost error: " + err.Error()) }) opts.SetReconnectingHandler(func(c MQTT.Client, options *MQTT.ClientOptions) { + time.Sleep(5 * time.Second) syslog.Notice("mqtt reconnecting") }) opts.SetOnConnectHandler(func(c MQTT.Client) {