Also serialize the routing and preference

This commit is contained in:
Martijn van Groningen 2013-07-22 15:16:29 +02:00
parent d310b94904
commit 2f7d1189b1

View File

@ -170,17 +170,21 @@ public class PercolateRequest extends BroadcastOperationRequest<PercolateRequest
@Override @Override
public void readFrom(StreamInput in) throws IOException { public void readFrom(StreamInput in) throws IOException {
super.readFrom(in); super.readFrom(in);
startTime = in.readVLong();
documentType = in.readString(); documentType = in.readString();
routing = in.readOptionalString();
preference = in.readOptionalString();
documentUnsafe = false; documentUnsafe = false;
documentSource = in.readBytesReference(); documentSource = in.readBytesReference();
startTime = in.readVLong();
} }
@Override @Override
public void writeTo(StreamOutput out) throws IOException { public void writeTo(StreamOutput out) throws IOException {
super.writeTo(out); super.writeTo(out);
out.writeVLong(startTime);
out.writeString(documentType); out.writeString(documentType);
out.writeOptionalString(routing);
out.writeOptionalString(preference);
out.writeBytesReference(documentSource); out.writeBytesReference(documentSource);
out.writeVLong(startTime);
} }
} }