mq options

This commit is contained in:
abhishek9686 2024-11-21 13:27:08 +04:00
parent 9ec8283659
commit 10b93d0118

View file

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