From b7dec8f65e4277c3e949358338f16e297d674c54 Mon Sep 17 00:00:00 2001
From: andsel <selva.andre@gmail.com>
Date: Wed, 19 Oct 2016 21:45:42 +0200
Subject: [PATCH] Minor change, just log in disconnet decoder

---
 .../java/io/moquette/parser/netty/DisconnectDecoder.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/netty_parser/src/main/java/io/moquette/parser/netty/DisconnectDecoder.java b/netty_parser/src/main/java/io/moquette/parser/netty/DisconnectDecoder.java
index 34233063..6611468f 100644
--- a/netty_parser/src/main/java/io/moquette/parser/netty/DisconnectDecoder.java
+++ b/netty_parser/src/main/java/io/moquette/parser/netty/DisconnectDecoder.java
@@ -19,6 +19,8 @@ import io.netty.buffer.ByteBuf;
 import io.netty.util.AttributeMap;
 import java.util.List;
 import io.moquette.parser.proto.messages.DisconnectMessage;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  *
@@ -26,6 +28,8 @@ import io.moquette.parser.proto.messages.DisconnectMessage;
  */
 class DisconnectDecoder extends DemuxDecoder {
 
+    private static Logger LOG = LoggerFactory.getLogger(DisconnectDecoder.class);
+
     @Override
     void decode(AttributeMap ctx, ByteBuf in, List<Object> out) throws Exception {
         //Common decoding part
@@ -35,6 +39,7 @@ class DisconnectDecoder extends DemuxDecoder {
             in.resetReaderIndex();
             return;
         }
+        LOG.debug("Decoding disconnect");
         out.add(message);
     }