|
@@ -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 {
|