From b9fa3758f7d60e7ad944945b908827ed7c77a401 Mon Sep 17 00:00:00 2001
From: Rina Fujino <rina.fujino@cumulocity.com>
Date: Wed, 16 Oct 2019 13:45:44 +0200
Subject: [PATCH] [MTM-28530][fix]srreporter: Set all mqtt cleansession
 parameters true

---
 src/srreporter.cc | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/srreporter.cc b/src/srreporter.cc
index 14f7598..a937157 100644
--- a/src/srreporter.cc
+++ b/src/srreporter.cc
@@ -670,7 +670,7 @@ static int exp_send(void *net, bool ishttp, const string &data, SrQueue<SrOpBatc
         {
             if (mqtt->publish("s/ul", data, 2))
             {
-                _mqtt_connect(mqtt, false, xid);
+                _mqtt_connect(mqtt, true, xid);
             }
             else
             {
@@ -705,7 +705,7 @@ void *SrReporter::func(void *arg)
         rpt->mqtt->addMsgHandler("s/ol/" + rpt->xid, &mh);
         rpt->mqtt->addMsgHandler("s/e", &mherr);
 
-        _mqtt_connect(rpt->mqtt.get(), false, rpt->xid);
+        _mqtt_connect(rpt->mqtt.get(), true, rpt->xid);
     }
 
     if (rpt->isfilebuf)
@@ -761,7 +761,7 @@ void *SrReporter::func(void *arg)
 
         if (rpt->mqtt && rpt->mqtt->yield(1000) == -1)
         {
-            _mqtt_connect(rpt->mqtt.get(), false, rpt->xid);
+            _mqtt_connect(rpt->mqtt.get(), true, rpt->xid);
         }
 
         aggre = aggregate(rpt->out, pager, rpt->isfilebuf, rpt->xid);