diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java index b81c29e5..868326ef 100644 --- a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java +++ b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SubscriptionsStore.java @@ -136,7 +136,7 @@ public class SubscriptionsStore { } // private List subscriptions = new ArrayList(); - private TreeNode subscriptions = new TreeNode(null); + private TreeNode subscriptionsRoot = new TreeNode(null); public void add(Subscription newSubscription) { List tokens = new ArrayList(); @@ -147,7 +147,7 @@ public class SubscriptionsStore { Logger.getLogger(SubscriptionsStore.class.getName()).log(Level.SEVERE, null, ex); } - TreeNode current = subscriptions; + TreeNode current = subscriptionsRoot; for (Token token : tokens) { TreeNode matchingChildren; @@ -172,7 +172,7 @@ public class SubscriptionsStore { //TODO handle the parse exception Logger.getLogger(SubscriptionsStore.class.getName()).log(Level.SEVERE, null, ex); } - TreeNode current = subscriptions; + TreeNode current = subscriptionsRoot; for (Token token : tokens) { current = current.matchNext(token); if (current == null) { @@ -191,7 +191,7 @@ public class SubscriptionsStore { } public int size() { - return subscriptions.size(); + return subscriptionsRoot.size(); } protected List splitTopic(String topic) throws ParseException {