fixing
git-svn-id: https://svn.apache.org/repos/asf/activemq/sandbox/activemq-protobuf@695997 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/activemq-protobuf/src/main/java/org/apache/activemq/protobuf/BaseMessage.java b/activemq-protobuf/src/main/java/org/apache/activemq/protobuf/BaseMessage.java
index a7f7734..a885bb6 100644
--- a/activemq-protobuf/src/main/java/org/apache/activemq/protobuf/BaseMessage.java
+++ b/activemq-protobuf/src/main/java/org/apache/activemq/protobuf/BaseMessage.java
@@ -94,7 +94,7 @@
try {
byte[] result = new byte[serializedSize()];
CodedOutputStream output = CodedOutputStream.newInstance(result);
- writeTo(output);
+ writePartialTo(output);
output.checkNoSpaceLeft();
return result;
} catch (IOException e) {
@@ -176,14 +176,12 @@
public T mergeFrom(InputStream input) throws IOException {
CodedInputStream codedInput = CodedInputStream.newInstance(input);
mergeFrom(codedInput);
- codedInput.checkLastTagWas(0);
return (T)this;
}
public T mergeFrom(InputStream input, ExtensionRegistry extensionRegistry) throws IOException {
CodedInputStream codedInput = CodedInputStream.newInstance(input);
mergeFrom(codedInput, extensionRegistry);
- codedInput.checkLastTagWas(0);
return (T)this;
}