broker: notify when client connection lost

broker/src/main/java/io/moquette/spi/impl/BrokerInterceptor.java

@@ -72,6 +72,18 @@ final class BrokerInterceptor implements Interceptor {
         }
     }
 
+    @Override
+    public void notifyClientConnectionLost(final String clientID, final String username) {
+        for (final InterceptHandler handler : this.handlers) {
+            executor.execute(new Runnable() {
+                @Override
+                public void run() {
+                    handler.onConnectionLost(new InterceptConnectionLostMessage(clientID, username));
+                }
+            });
+        }
+    }
+
     @Override
     public void notifyTopicPublished(final PublishMessage msg, final String clientID, final String username) {
         for (final InterceptHandler handler : this.handlers) {

broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java

@@ -704,6 +704,9 @@ public class ProtocolProcessor {
             forwardPublishWill(will, clientID);
             m_willStore.remove(clientID);
         }
+
+        String username = NettyUtils.userName(channel);
+        m_interceptor.notifyClientConnectionLost(clientID, username);
     }
 
     /**