From 42a56dc9a956be3dd91b32c3d74eb905e49d44f0 Mon Sep 17 00:00:00 2001 From: boseji Date: Mon, 19 Aug 2024 12:28:36 +0530 Subject: [PATCH] =?UTF-8?q?=E0=A4=AA=E0=A5=81=E0=A4=A8=E0=A4=B0=E0=A5=80?= =?UTF-8?q?=E0=A4=95=E0=A5=8D=E0=A4=B7=E0=A4=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mqtt.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/mqtt.go b/mqtt.go index 310ea23..92610e6 100644 --- a/mqtt.go +++ b/mqtt.go @@ -103,6 +103,9 @@ func setupMQTT(m cfg, cancel() }) + // Clean Sessions for each run + opts.SetCleanSession(true) + return opts }