Fixed the clean session to true coming from a previous clean session false

2012-08-10 21:15:26 +02:00
parent bc6189c65e
commit 8a21aae034
1 changed files with 8 additions and 1 deletions
@@ -122,7 +122,14 @@ public class MQTTHandler extends IoHandlerAdapter implements INotifier {
            }
        }

-        //TODO handle clean session flag once the QoS1 and QoS2
+        //TODO for QoS1 and QoS remember to store all the messages arrived to
+        //the dormat subscriptionsonce the QoS1 and QoS2
+        //handle clean session flag
+        if (msg.isCleanSession()) {
+            //remove all prev subscriptions
+            //cleanup topic subscriptions
+            m_messaging.removeSubscriptions(msg.getClientID());
+        }

        ConnAckMessage okResp = new ConnAckMessage();
        okResp.setReturnCode(ConnAckMessage.CONNECTION_ACCEPTED);