From 29c5d6cecad6fcaeb4a57bac85895d6516294e28 Mon Sep 17 00:00:00 2001 From: abhishek9686 Date: Mon, 25 Mar 2024 15:23:03 +0700 Subject: [PATCH] add debug log of mq client id --- mq/mq.go | 1 + 1 file changed, 1 insertion(+) diff --git a/mq/mq.go b/mq/mq.go index b09128c4..4ace4450 100644 --- a/mq/mq.go +++ b/mq/mq.go @@ -70,6 +70,7 @@ func SetupMQTT() { opts := mqtt.NewClientOptions() setMqOptions(servercfg.GetMqUserName(), servercfg.GetMqPassword(), opts) + logger.Log(0, "Mq Client Connecting with Random ID: ", opts.ClientID) opts.SetOnConnectHandler(func(client mqtt.Client) { serverName := servercfg.GetServer() if token := client.Subscribe(fmt.Sprintf("update/%s/#", serverName), 0, mqtt.MessageHandler(UpdateNode)); token.WaitTimeout(MQ_TIMEOUT*time.Second) && token.Error() != nil {