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 out) throws Exception { //Common decoding part @@ -35,6 +39,7 @@ class DisconnectDecoder extends DemuxDecoder { in.resetReaderIndex(); return; } + LOG.debug("Decoding disconnect"); out.add(message); }