X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fmessages%2FBatchedModificationsReply.java;h=070b143cda8ff70d9350b6d6a73e6ad525b8d483;hp=a10c6ac3fb1b6d673a9f8e5b3517e72cebdde9f5;hb=24c074a4b32ac97980a652b78824b7c2f97ffb78;hpb=edfebf2ecb683a0b16286977c43efa5a67b6744a diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/BatchedModificationsReply.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/BatchedModificationsReply.java index a10c6ac3fb..070b143cda 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/BatchedModificationsReply.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/BatchedModificationsReply.java @@ -19,11 +19,7 @@ import java.io.ObjectOutput; public class BatchedModificationsReply extends VersionedExternalizableMessage { private static final long serialVersionUID = 1L; - private static final byte COHORT_PATH_NOT_PRESENT = 0; - private static final byte COHORT_PATH_PRESENT = 1; - private int numBatched; - private String cohortPath; public BatchedModificationsReply() { } @@ -32,52 +28,26 @@ public class BatchedModificationsReply extends VersionedExternalizableMessage { this.numBatched = numBatched; } - public BatchedModificationsReply(int numBatched, String cohortPath) { - this.numBatched = numBatched; - this.cohortPath = cohortPath; - } - public int getNumBatched() { return numBatched; } - public String getCohortPath() { - return cohortPath; - } - @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { super.readExternal(in); numBatched = in.readInt(); - - if(in.readByte() == COHORT_PATH_PRESENT) { - cohortPath = in.readUTF(); - } } @Override public void writeExternal(ObjectOutput out) throws IOException { super.writeExternal(out); out.writeInt(numBatched); - - if(cohortPath != null) { - out.writeByte(COHORT_PATH_PRESENT); - out.writeUTF(cohortPath); - } else { - out.writeByte(COHORT_PATH_NOT_PRESENT); - } - } - - @Override - public Object toSerializable() { - return this; } @Override public String toString() { StringBuilder builder = new StringBuilder(); - builder.append("BatchedModificationsReply [numBatched=").append(numBatched).append(", cohortPath=") - .append(cohortPath).append("]"); + builder.append("BatchedModificationsReply [numBatched=").append(numBatched).append("]"); return builder.toString(); } }