TcpChannelInitializer.java

public class TcpChannelInitializer extends ChannelInitializer<SocketChannel> {
	
	@Override
	public void initChannel(SocketChannel ch) throws Exception {
		ChannelPipeline pipeline = ch.pipeline();
		pipeline.addLast(
				new MqttMessageNewEncoder(),
				new MqttMessageNewDecoder(),
				new MqttMessageHandler());
	}
}