From 76c2857d482dedfa60bcc90c05174283aec9ebc3 Mon Sep 17 00:00:00 2001 From: Hylke van der Schaaf Date: Fri, 19 May 2017 16:18:20 +0200 Subject: [PATCH] Terminate interceptor on shutdown. --- .../io/moquette/spi/impl/ProtocolProcessorBootstrapper.java | 2 ++ 1 file changed, 2 insertions(+) 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() {