From 558b4a4c6437704d9be43469987fe43f8676d229 Mon Sep 17 00:00:00 2001 From: andsel Date: Sun, 27 Nov 2016 19:34:51 +0100 Subject: [PATCH] Changed SUBSCRIPTION processing to be based on concurrent FSM --- .../src/main/java/io/moquette/spi/impl/ProtocolProcessor.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java index 4a2e216c..fa8c8690 100644 --- a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java +++ b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java @@ -98,10 +98,6 @@ public class ProtocolProcessor { private enum SubscriptionState { STORED, VERIFIED - //Connection states - //DISCONNECTED, SENDACK, SESSION_CREATED, MESSAGES_REPUBLISHED, ESTABLISHED, - //Disconnection states - //SUBSCRIPTIONS_REMOVED, MESSAGES_DROPPED, INTERCEPTORS_NOTIFIED; } private class RunningSubscription {