package chat.server.netty; import java.util.List; import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerContext; import io.netty.handler.codec.MessageToMessageDecoder; import io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame; public class WebSocketFrameToByteBufDecoder extends MessageToMessageDecoder { @Override protected void decode(ChannelHandlerContext chc, BinaryWebSocketFrame frame, List out) throws Exception { // convert the frame to a ByteBuf ByteBuf bb = frame.content(); bb.retain(); out.add(bb); } }