From 10081b3880daabd267758633cb011c9ed52cbe71 Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Fri, 19 Sep 2014 22:49:23 +0200 Subject: [PATCH] Minor change, wiped subscription also from persistent store --- .../messaging/spi/impl/subscriptions/SubscriptionsStore.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java index de3dd3c4..4a592a12 100644 --- a/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java +++ b/broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStore.java @@ -169,9 +169,8 @@ public class SubscriptionsStore { */ public void removeForClient(String clientID) { subscriptions.removeClientSubscriptions(clientID); - //TODO persist the update - //remove from log all subscriptions -// m_storageService.removeAllSubscriptions(clientID); + //persist the update + m_sessionsStore.wipeSubscriptions(clientID); } public void deactivate(String clientID) {