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%2FAbortTransaction.java;h=57a4e395fa9e5b489befa1a619c433412cdcfbaf;hb=50a2f5eb1c94650bc1be1e49d3a5382a1a74a9b3;hp=4cf713a0b3efa0a16aa68a9230af81bf568aa0ad;hpb=da6ca13e3f8ecb73a62f7e8f9ae3bdcae9d851f8;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/AbortTransaction.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/AbortTransaction.java index 4cf713a0b3..57a4e395fa 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/AbortTransaction.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/AbortTransaction.java @@ -8,5 +8,25 @@ package org.opendaylight.controller.cluster.datastore.messages; -public class AbortTransaction { +import com.google.common.base.Preconditions; +import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; + +public class AbortTransaction extends AbstractThreePhaseCommitMessage { + private static final long serialVersionUID = 1L; + + public AbortTransaction() { + } + + public AbortTransaction(TransactionIdentifier transactionID, final short version) { + super(transactionID, version); + } + + public static AbortTransaction fromSerializable(Object serializable) { + Preconditions.checkArgument(serializable instanceof AbortTransaction); + return (AbortTransaction)serializable; + } + + public static boolean isSerializedType(Object message) { + return message instanceof AbortTransaction; + } }