Подскажите что не так делаю. Ниже работающий правильно вариант, но без Lenght decodera.
@Override
public ChannelPipeline getPipeline() throws Exception {
final ChannelPipeline pipeline = Channels.pipeline();
pipeline.addLast("decoder", new PacketFrameDecoder());
pipeline.addLast("encoder", new PacketFrameEncoder());
pipeline.addLast("executor", getExecutorHandler());
pipeline.addLast("handler", new ClientChannelHandler()); //Client logic
return pipeline;
}
Code: Java
Если его добавить , то не один не отрабатывает, только коннект происходит.
public class LengthDecoder extends LengthFieldBasedFrameDecoder {
private static final Logger log = LoggerFactory.getLogger(LengthDecoder.class.getSimpleName());
public LengthDecoder() {
super(Short.MAX_VALUE, 0, 2);
}
@Override
protected Object decode(ChannelHandlerContext ctx, Channel channel, ChannelBuffer buffer) throws Exception {
log.info("Lengh Based Decoder, decode()");
log.info(NetUtils.getHexDump(buffer.array()));
return super.decode(ctx, channel, buffer); //To change body of overridden methods use File | Settings | File Templates.
}
}
Code: Java
Добавлял после первого декодера.