Netty 4.0.0.CR5 UDP pipeline example

gistfile1.java

 public void run() throws Exception {
        EventLoopGroup udpGroup = new NioEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap();
            b.group(udpGroup)
            .channel(NioDatagramChannel.class)
            .handler(new ChannelInitializer<DatagramChannel>() {
                @Override
                protected void initChannel(DatagramChannel ch) throws Exception {
                    ChannelPipeline p = ch.pipeline();
                    p.addLast("udpDecoder", new MessageToMessageDecoder<DatagramPacket>() {
                        @Override
                        protected void decode(ChannelHandlerContext ctx, DatagramPacket msg, MessageList<Object> out) throws Exception {
                            out.add(msg.content());
                            msg.retain();
                        }
                    });
                    p.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(65535, 2, 2));
                }
            });
            b.bind(port).sync().channel().closeFuture().sync();
        } finally {
            udpGroup.shutdownGracefully();
        }
    }