From 3e89bc5d2ccbddd1b354c0dad95a2e1a80c5b3dc Mon Sep 17 00:00:00 2001
From: bcw <bcw104@126.com>
Date: Mon, 24 Oct 2016 11:37:10 +0800
Subject: [PATCH] =?UTF-8?q?notify=20when=20client=20connection=20lost?=
 =?UTF-8?q?=EF=BC=9B=20implement=20onConnectionLost()=20method=20in=20Abst?=
 =?UTF-8?q?ractInterceptHandler.java;?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../io/moquette/interception/AbstractInterceptHandler.java   | 3 +++
 .../java/io/moquette/spi/impl/BrokerInterceptorTest.java     | 5 +++++
 2 files changed, 8 insertions(+)

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);