Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import io.netty.buffer.ByteBuf;
- import io.netty.channel.ChannelHandlerContext;
- import io.netty.handler.codec.ByteToMessageDecoder;
- import java.io.IOException;
- import java.util.List;
- public class T1Decoder extends ByteToMessageDecoder {
- @Override
- protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
- in.markReaderIndex();
- try{
- System.out.println("t1 decoding! "+in);
- int id = in.readInt();
- if (id>255){
- throw new IOException("Bad id!");
- }else {
- T1Packet t1Packet = new T1Packet(id);
- t1Packet.read(in);
- out.add(t1Packet);
- }
- }catch (Exception e){
- in.resetReaderIndex();
- return;
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement