Explorar el Código

configure mq conn params

abhishek9686 hace 1 año
padre
commit
a3b0dd3b58
Se han modificado 1 ficheros con 2 adiciones y 2 borrados
  1. 2 2
      mq/mq.go

+ 2 - 2
mq/mq.go

@@ -34,8 +34,8 @@ func setMqOptions(user, password string, opts *mqtt.ClientOptions) {
 	opts.SetAutoReconnect(true)
 	opts.SetConnectRetry(true)
 	opts.SetCleanSession(true)
-	opts.SetConnectRetryInterval(time.Second * 4)
-	opts.SetKeepAlive(time.Minute)
+	opts.SetConnectRetryInterval(time.Second * 3)
+	opts.SetKeepAlive(time.Second * 5)
 	opts.SetCleanSession(true)
 	opts.SetWriteTimeout(time.Minute)
 }