import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;
+import java.util.Arrays;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
@Sharable
final class ProtocolMessageEncoder extends MessageToByteEncoder<ProtocolMessage> {
+ private final static Logger logger = LoggerFactory.getLogger(ProtocolMessageEncoder.class);
+
private final ProtocolMessageFactory factory;
public ProtocolMessageEncoder(final ProtocolMessageFactory factory) {
@Override
protected void encode(final ChannelHandlerContext ctx, final ProtocolMessage msg, final ByteBuf out) throws Exception {
+ logger.debug("Sent to encode : {}", Arrays.toString(ctx.channel().pipeline().names().toArray()));
out.writeBytes(this.factory.put(msg));
}
}