Kaynağa Gözat

Merge pull request #2997 from gravitl/NET-1165

NET-1165: Comment out mq reconnect logic
Abhishek K 1 yıl önce
ebeveyn
işleme
20fab134cb
1 değiştirilmiş dosya ile 3 ekleme ve 3 silme
  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)