From 81b40f00244c55122ad467ed5a153bd201d34db4 Mon Sep 17 00:00:00 2001 From: Shabirmean Date: Wed, 6 Jan 2016 14:30:26 +0530 Subject: [PATCH] Setting "cleanSession" to true in order to overcome temporary bug in MB --- .../carbon/device/mgt/iot/controlqueue/mqtt/MqttSubscriber.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/components/device-mgt-iot/org.wso2.carbon.device.mgt.iot/src/main/java/org/wso2/carbon/device/mgt/iot/controlqueue/mqtt/MqttSubscriber.java b/components/device-mgt-iot/org.wso2.carbon.device.mgt.iot/src/main/java/org/wso2/carbon/device/mgt/iot/controlqueue/mqtt/MqttSubscriber.java index a80af1dc77..8b28a508fa 100644 --- a/components/device-mgt-iot/org.wso2.carbon.device.mgt.iot/src/main/java/org/wso2/carbon/device/mgt/iot/controlqueue/mqtt/MqttSubscriber.java +++ b/components/device-mgt-iot/org.wso2.carbon.device.mgt.iot/src/main/java/org/wso2/carbon/device/mgt/iot/controlqueue/mqtt/MqttSubscriber.java @@ -120,7 +120,7 @@ public abstract class MqttSubscriber implements MqttCallback { } options = new MqttConnectOptions(); - options.setCleanSession(false); + options.setCleanSession(true); options.setWill(clientWillTopic, "connection crashed".getBytes(StandardCharsets.UTF_8), 2, true); client.setCallback(this); }