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