Преглед на файлове

Revert "mq options"

This reverts commit 10b93d01185478141a12fe7fc8f973d848d28e35.
abhishek9686 преди 9 месеца
родител
ревизия
db5d306a85
променени са 1 файла, в които са добавени 2 реда и са изтрити 3 реда
  1. 2 3
      mq/mq.go

+ 2 - 3
mq/mq.go

@@ -34,9 +34,8 @@ func setMqOptions(user, password string, opts *mqtt.ClientOptions) {
 	opts.SetAutoReconnect(true)
 	opts.SetConnectRetry(true)
 	opts.SetCleanSession(true)
-	opts.SetConnectRetryInterval(time.Second * 3)
-	opts.SetKeepAlive(120 * time.Second)
-	opts.SetPingTimeout(30 * time.Second)
+	opts.SetConnectRetryInterval(time.Second * 1)
+	opts.SetKeepAlive(time.Second * 10)
 	opts.SetOrderMatters(false)
 	opts.SetWriteTimeout(time.Minute)
 }