gistfile1.java

    private static class OpenFlowDecoder extends OneToOneDecoder {
        @Override
        protected Object decode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception {
            if (!(msg instanceof ChannelBuffer)) {
                return msg;
            }

            ChannelBuffer channelBuffer = (ChannelBuffer)msg;
            ByteBuffer byteBuffer = channelBuffer.toByteBuffer();
            List<OFMessage> messages = factory.parseMessages(byteBuffer);
            return messages.get(0);
        }
    }