1 package net.anyflow.lannister.server;
2
3 import java.util.List;
4
5 import io.netty.buffer.ByteBuf;
6 import io.netty.channel.ChannelHandlerContext;
7 import io.netty.handler.codec.MessageToMessageCodec;
8 import io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame;
9
10 public class MqttWebSocketCodec extends MessageToMessageCodec<BinaryWebSocketFrame, ByteBuf> {
11 @Override
12 protected void encode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) throws Exception {
13 out.add(new BinaryWebSocketFrame(msg.retain()));
14 }
15
16 @Override
17 protected void decode(ChannelHandlerContext ctx, BinaryWebSocketFrame msg, List<Object> out) throws Exception {
18 out.add(msg.retain().content());
19 }
20 }