|
|
@@ -56,8 +56,8 @@ func initMqttClient(conf *MqttConfig) (mc MQTT.Client, err error) {
|
|
|
opts.AddBroker(broker)
|
|
|
}
|
|
|
opts.SetClientID(fmt.Sprintf("%s_%s", conf.ClientId, guid.S())).
|
|
|
- SetUsername(conf.User).SetPassword(conf.Password)
|
|
|
- //SetConnectRetry(true)
|
|
|
+ SetUsername(conf.User).SetPassword(conf.Password).
|
|
|
+ SetConnectRetry(true)
|
|
|
opts.SetConnectionAttemptHandler(func(broker *url.URL, tlsCfg *tls.Config) *tls.Config {
|
|
|
server.Log.Infof("connect to %s", broker.String())
|
|
|
return tlsCfg
|
liuxiulin