Forráskód Böngészése

comment out mq reconnect logic

abhishek9686 1 éve
szülő
commit
7bd88d8184
1 módosított fájl, 3 hozzáadás és 3 törlés
  1. 3 3
      mq/mq.go

+ 3 - 3
mq/mq.go

@@ -96,9 +96,9 @@ func SetupMQTT(fatal bool) {
 	})
 	opts.SetConnectionLostHandler(func(c mqtt.Client, e error) {
 		slog.Warn("detected broker connection lost", "err", e.Error())
-		c.Disconnect(250)
-		slog.Info("re-initiating MQ connection")
-		SetupMQTT(false)
+		// c.Disconnect(250)
+		// slog.Info("re-initiating MQ connection")
+		// SetupMQTT(false)
 
 	})
 	mqclient = mqtt.NewClient(opts)