|
@@ -69,7 +69,7 @@ func SetupMQTT(fatal bool) {
|
|
|
|
|
|
|
|
opts := mqtt.NewClientOptions()
|
|
opts := mqtt.NewClientOptions()
|
|
|
setMqOptions(servercfg.GetMqUserName(), servercfg.GetMqPassword(), opts)
|
|
setMqOptions(servercfg.GetMqUserName(), servercfg.GetMqPassword(), opts)
|
|
|
- logger.Log(0, "Mq Client Connecting with Random ID: ", opts.ClientID)
|
|
|
|
|
|
|
+ logger.Log(0, "Mq Client Connecting with ID: ", opts.ClientID)
|
|
|
opts.SetOnConnectHandler(func(client mqtt.Client) {
|
|
opts.SetOnConnectHandler(func(client mqtt.Client) {
|
|
|
serverName := servercfg.GetServer()
|
|
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 {
|
|
if token := client.Subscribe(fmt.Sprintf("update/%s/#", serverName), 0, mqtt.MessageHandler(UpdateNode)); token.WaitTimeout(MQ_TIMEOUT*time.Second) && token.Error() != nil {
|
abhishek9686