Minor change, just log in disconnet decoder

This commit is contained in:
andsel
2016-11-05 18:29:08 +01:00
parent ccdb50e760
commit b7dec8f65e
@@ -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);
}