MqttMessageWebSocketFrameEncoder.java 文件源码

@Override
protected void encode(ChannelHandlerContext ctx, Message msg,
        List<Object> out) throws Exception {
    if (msg == null || !(msg instanceof Message))
        return;

    byte[] data = ((Message) msg).toBytes();

    out.add(new BinaryWebSocketFrame(Unpooled.wrappedBuffer(data)));
}