fix: reuse session to receive data from subscriptions after reconnect

grafana · Apr 29, 2024 · 759891c · 759891c
1 parent d3075c9
commit 759891c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/mqtt/client.go b/pkg/mqtt/client.go
@@ -47,6 +47,7 @@ func NewClient(o Options) (Client, error) {
 	opts.SetPingTimeout(60 * time.Second)
 	opts.SetKeepAlive(60 * time.Second)
 	opts.SetAutoReconnect(true)
+	opts.SetCleanSession(false)
 	opts.SetMaxReconnectInterval(10 * time.Second)
 	opts.SetConnectionLostHandler(func(c paho.Client, err error) {
 		log.DefaultLogger.Error("MQTT Connection lost", "error", err)