|
|
@@ -71,7 +71,7 @@ func (M *MQTTBrokerNode) Init(ctx ruleEngine.Context, config string) error {
|
|
|
var opt MQTT.ClientOptions
|
|
|
opt.ClientID = "MQTT_NODE_" + guid.S()
|
|
|
opt.CleanSession = M.config.ClearSession
|
|
|
- opt.KeepAlive = 30
|
|
|
+ opt.KeepAlive = 120
|
|
|
opt.ConnectTimeout = time.Duration(M.config.Timeout) * time.Second
|
|
|
switch M.config.Credentials {
|
|
|
case "Basic":
|
