From 74aaf603e233894a5407b3e667fe904589da14a5 Mon Sep 17 00:00:00 2001 From: andrea Date: Sun, 9 Aug 2015 12:16:58 +0200 Subject: [PATCH] Fixed issue #69 --- ChangeLog.txt | 1 + .../java/org/eclipse/moquette/spi/impl/ProtocolProcessor.java | 2 +- pom.xml | 4 ++++ 3 files changed, 6 insertions(+), 1 deletion(-) diff --git a/ChangeLog.txt b/ChangeLog.txt index 595d841d..87192b39 100644 --- a/ChangeLog.txt +++ b/ChangeLog.txt @@ -2,6 +2,7 @@ Version 0.8: Introduced authenticator and authorizator implementations. Fixed bug, doesn't close the channel when connect doesn't contains a valid proto name, issue #65 Fixed bug, does not check for zero length topic (filters) in PUBLISH, SUBSCRIBE, and UNSUBSCRIBE, issue #67 + Fixed issue #69 Version 0.7: Fix issue #38, added aligned to MQTT 3.1.1 diff --git a/broker/src/main/java/org/eclipse/moquette/spi/impl/ProtocolProcessor.java b/broker/src/main/java/org/eclipse/moquette/spi/impl/ProtocolProcessor.java index 54e73651..4d259a61 100644 --- a/broker/src/main/java/org/eclipse/moquette/spi/impl/ProtocolProcessor.java +++ b/broker/src/main/java/org/eclipse/moquette/spi/impl/ProtocolProcessor.java @@ -289,7 +289,7 @@ class ProtocolProcessor implements EventHandler { private void cleanSession(String clientID) { LOG.info("cleaning old saved subscriptions for client <{}>", clientID); //remove from log all subscriptions - m_sessionsStore.wipeSubscriptions(clientID); + //m_sessionsStore.wipeSubscriptions(clientID); subscriptions.removeForClient(clientID); //remove also the messages stored of type QoS1/2 diff --git a/pom.xml b/pom.xml index d7c9f5f8..6e8dc7ca 100644 --- a/pom.xml +++ b/pom.xml @@ -46,6 +46,10 @@ Luca Capra https://github.com/muka + + Wagner Macedo + https://github.com/wagnerluis1982 +