diff --git a/broker/src/main/java/io/moquette/interception/AbstractInterceptHandler.java b/broker/src/main/java/io/moquette/interception/AbstractInterceptHandler.java index b64c03e6..c1a75447 100644 --- a/broker/src/main/java/io/moquette/interception/AbstractInterceptHandler.java +++ b/broker/src/main/java/io/moquette/interception/AbstractInterceptHandler.java @@ -30,6 +30,9 @@ public abstract class AbstractInterceptHandler implements InterceptHandler { @Override public void onDisconnect(InterceptDisconnectMessage msg) {} + @Override + public void onConnectionLost(InterceptConnectionLostMessage msg) {} + @Override public void onPublish(InterceptPublishMessage msg) {} diff --git a/broker/src/test/java/io/moquette/spi/impl/BrokerInterceptorTest.java b/broker/src/test/java/io/moquette/spi/impl/BrokerInterceptorTest.java index b84b4896..3a5fec48 100644 --- a/broker/src/test/java/io/moquette/spi/impl/BrokerInterceptorTest.java +++ b/broker/src/test/java/io/moquette/spi/impl/BrokerInterceptorTest.java @@ -51,6 +51,11 @@ public class BrokerInterceptorTest { n.set(50); } + @Override + public void onConnectionLost(InterceptConnectionLostMessage msg) { + n.set(30); + } + @Override public void onPublish(InterceptPublishMessage msg) { n.set(60);