Merge pull request #342 from hylkevds/master

Terminate processor on shutdown.

broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java

@@ -943,4 +943,9 @@ public class ProtocolProcessor {
     public ISessionsStore getSessionsStore() {
         return m_sessionsStore;
     }
+
+    public void shutdown() {
+        if (m_interceptor != null)
+            m_interceptor.stop();
+    }
 }

broker/src/main/java/io/moquette/spi/impl/ProtocolProcessorBootstrapper.java

@@ -254,8 +254,8 @@ public class ProtocolProcessorBootstrapper {
     public void shutdown() {
         if (storeShutdown != null)
             storeShutdown.run();
-//        if (m_interceptor != null)
-//            m_interceptor.stop();
+        if (m_processor != null)
+            m_processor.shutdown();
     }
 
     public ConnectionDescriptorStore getConnectionDescriptors() {