diff --git a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessorBootstrapper.java b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessorBootstrapper.java index ae7cf9ed..0430b07d 100644 --- a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessorBootstrapper.java +++ b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessorBootstrapper.java @@ -263,6 +263,8 @@ public class ProtocolProcessorBootstrapper { public void shutdown() { if (storeShutdown != null) storeShutdown.run(); + if (m_interceptor != null) + m_interceptor.stop(); } public ConnectionDescriptorStore getConnectionDescriptors() {