ChannelBuffer buf = (ChannelBuffer) encoder.encode(null, null, query);
ChannelBuffer buf2 = new BigEndianHeapChannelBuffer(buf.readableBytes() + 8);
buf2.writeInt(123);
buf2.writeBytes(buf);
buf2.readInt();
ProtobufDecoder decoder = new ProtobufDecoder();
decoder.addMessageType(Query.getDefaultInstance());
Message message = (Message) decoder.decode(null, null, buf2);
assertEquals(query, message);
}