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 72159b5f..191bd358 100644 --- a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessorBootstrapper.java +++ b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessorBootstrapper.java @@ -268,6 +268,8 @@ public class ProtocolProcessorBootstrapper { public void shutdown() { if (storeShutdown != null) storeShutdown.run(); + if (m_interceptor != null) + m_interceptor.stop(); } public ConnectionDescriptorStore getConnectionDescriptors() {