X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fmessages%2FCloseTransaction.java;h=738a74f17b1a3d985bd0862dd93fbe3d8e861bf0;hb=11e722671c6dc194761471038a4e3ca5f7fd8970;hp=6809f4b1357c1e7140ad7366b40dfb1511934180;hpb=40322f77dfe223779916dbe047b500a87fa080e3;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/CloseTransaction.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/CloseTransaction.java index 6809f4b135..738a74f17b 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/CloseTransaction.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/CloseTransaction.java @@ -8,5 +8,28 @@ package org.opendaylight.controller.cluster.datastore.messages; -public class CloseTransaction { +import org.opendaylight.controller.cluster.datastore.DataStoreVersions; +import org.opendaylight.controller.protobuff.messages.transaction.ShardTransactionMessages; + +public class CloseTransaction extends VersionedExternalizableMessage { + private static final long serialVersionUID = 1L; + + private static final Object SERIALIZED_INSTANCE = + ShardTransactionMessages.CloseTransaction.newBuilder().build(); + + public CloseTransaction() { + } + + public CloseTransaction(short version) { + super(version); + } + + @Override + public Object toSerializable() { + return getVersion() >= DataStoreVersions.BORON_VERSION ? this : SERIALIZED_INSTANCE; + } + + public static boolean isSerializedType(Object message) { + return message instanceof CloseTransaction || message instanceof ShardTransactionMessages.CloseTransaction; + } }