17 lines
490 B
Java
17 lines
490 B
Java
package com.baeldung.netty;
|
|
|
|
import io.netty.buffer.ByteBuf;
|
|
import io.netty.channel.ChannelHandlerContext;
|
|
import io.netty.handler.codec.ReplayingDecoder;
|
|
|
|
import java.util.List;
|
|
|
|
public class ResponseDataDecoder extends ReplayingDecoder<ResponseData> {
|
|
|
|
@Override
|
|
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
|
|
ResponseData data = new ResponseData();
|
|
data.setIntValue(in.readInt());
|
|
out.add(data);
|
|
}
|
|
} |