Merge pull request #260 from kerberos-io/fix/set-clean-state

fix/set-clean-state
Set MQTT clean session to true and disable resume subscriptions
2026-09-13 11:46:40 +00:00 · 2026-03-09 16:56:36 +01:00 · 2026-03-09 15:50:40 +00:00
1 changed files with 3 additions and 3 deletions
--- a/machinery/src/routers/mqtt/main.go
+++ b/machinery/src/routers/mqtt/main.go
@@ -90,9 +90,9 @@ func ConfigureMQTT(configDirectory string, configuration *models.Configuration,

 		// Some extra options to make sure the connection behaves
 		// properly. More information here: github.com/eclipse/paho.mqtt.golang.
-		opts.SetCleanSession(false)
-		opts.SetResumeSubs(true)
-		opts.SetStore(mqtt.NewMemoryStore())
+		opts.SetCleanSession(true)
+		//opts.SetResumeSubs(true)
+		//opts.SetStore(mqtt.NewMemoryStore())
 		opts.SetConnectRetry(true)
 		opts.SetAutoReconnect(true)
 		opts.SetConnectRetryInterval(5 * time.Second)
Author	SHA1	Message	Date
Cédric Verstraeten	41a1d221fc	Merge pull request #260 from kerberos-io/fix/set-clean-state fix/set-clean-state	2026-03-09 16:56:36 +01:00
Cédric Verstraeten	eaacc93d2f	Set MQTT clean session to true and disable resume subscriptions	2026-03-09 15:50:40 +00:00