Вот мой код
channel.pipeline().addBefore("handler","new_handler",new ChannelInboundHandlerAdapter()
{
@Override
public void channelRead(ChannelHandlerContext ctx,Object msg)
{
if(msg instanceof ClassToTestFor)
{
//how do i cancel it here
return;
}
super.channelRead(ctx,msg);
}
});
По какой-то причине он обрабатывает определенные сообщения независимо от того, используете ли вы channelRead. Я очень запутался, и я очень плохо знаком с Нетти.