gistfile1.java

pipeline.addLast("encoder", new OneToOneEncoder() {
            @Override
            protected Object encode(ChannelHandlerContext channelHandlerContext, Channel channel, Object o) throws Exception
            {
                Server.getStatisticator().increaseResponses();
                Response response = (Response) o;

                byte[] bytes = response.getXML().getBytes();

                if (Server.isUseEncoder())
                {
                    bytes = AESEncryptor.encrypt(bytes);
                }

                ChannelBuffer buf = ChannelBuffers.dynamicBuffer();
                buf.writeBytes(bytes);

                return buf;
            }
        });