MqttMessageWebSocketFrameEncoder.java

@Sharable
public class MqttMessageWebSocketFrameEncoder extends
		MessageToMessageEncoder<Message> {
	@Override
	protected void encode(ChannelHandlerContext ctx, Message msg,
			List<Object> out) throws Exception {
		if (msg == null)
			return;

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

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