|
@@ -8,6 +8,7 @@ import (
|
|
|
|
|
|
mqtt "github.com/eclipse/paho.mqtt.golang"
|
|
|
"github.com/gravitl/netmaker/logger"
|
|
|
+ "github.com/gravitl/netmaker/logic"
|
|
|
"github.com/gravitl/netmaker/servercfg"
|
|
|
"golang.org/x/exp/slog"
|
|
|
)
|
|
@@ -27,7 +28,7 @@ var mqclient mqtt.Client
|
|
|
func setMqOptions(user, password string, opts *mqtt.ClientOptions) {
|
|
|
broker, _ := servercfg.GetMessageQueueEndpoint()
|
|
|
opts.AddBroker(broker)
|
|
|
- opts.ClientID = user
|
|
|
+ opts.ClientID = logic.RandomString(23)
|
|
|
opts.SetUsername(user)
|
|
|
opts.SetPassword(password)
|
|
|
opts.SetAutoReconnect(true)
|