From 61f0e261bfeb2b205532a6376f17bc739681169e Mon Sep 17 00:00:00 2001
From: andrea <andrea@samarcanda>
Date: Sat, 25 Aug 2012 11:32:30 +0200
Subject: [PATCH] Forced the TCP closing on DISCONNECT message

---
 .../main/java/org/dna/mqtt/moquette/server/MQTTHandler.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java b/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java
index 44d1a680..6bed0d07 100644
--- a/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java
+++ b/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java
@@ -202,6 +202,9 @@ public class MQTTHandler extends IoHandlerAdapter implements INotifier {
             //cleanup topic subscriptions
             m_messaging.removeSubscriptions(clientID);
         }
+        
+        //close the TCP connection
+        session.close(true);
     }
 
     @Override