We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d3075c9 commit 759891cCopy full SHA for 759891c
pkg/mqtt/client.go
@@ -47,6 +47,7 @@ func NewClient(o Options) (Client, error) {
47
opts.SetPingTimeout(60 * time.Second)
48
opts.SetKeepAlive(60 * time.Second)
49
opts.SetAutoReconnect(true)
50
+ opts.SetCleanSession(false)
51
opts.SetMaxReconnectInterval(10 * time.Second)
52
opts.SetConnectionLostHandler(func(c paho.Client, err error) {
53
log.DefaultLogger.Error("MQTT Connection lost", "error", err)
0 commit comments