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=4d1709660b7af992d4c382a2a38debb5c7d64fb9;hp=4cf713a0b3efa0a16aa68a9230af81bf568aa0ad;hpb=44c747db358bf0d49434d5f818121286b5928d4a;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; + } }