gistfile1.java

    private static class OpenFlowEncoder extends OneToOneEncoder {
        @Override
        protected Object encode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception {
            if (msg instanceof OFMessage) {
                OFMessage response = (OFMessage) msg;
                //  may have an bad effect on performance
                ByteBuffer buffer = ByteBuffer.allocate(response.getLength());
                response.writeTo(buffer);
                buffer.flip();
                return ChannelBuffers.wrappedBuffer(buffer);
            }

            return ChannelBuffers.EMPTY_BUFFER;
        }
    }