MqttMessageWebSocketFrameDecoder.java 文件源码

@Override
protected void decode(ChannelHandlerContext ctx,
        BinaryWebSocketFrame wsFrame, List<Object> out) throws Exception {
    ByteBuf buf = wsFrame.content();

    this.messageNewDecoder.decode(ctx, buf, out);
}