CodedInputStream cin = CodedInputStream.newInstance(in);
for (int i = 0; i < messageCount; i++) {
int size = cin.readRawVarint32();
int previous = cin.pushLimit(size);
OpenWire.Message message = OpenWire.Message.parseFrom(cin);
cin.popLimit(previous);
System.out.println("Reading message: " + i + " = " + message);
assertEquals("message.getPersistent()", true, message.getPersistent());
assertEquals("message.getProducerId()", 1234, message.getProducerId());
assertEquals("message.getProducerCounter()", i, message.getProducerCounter());