X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fcds-access-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fcommands%2FTransactionCanCommitSuccess.java;h=e6149bd5da226529e746a07e09314fde37759346;hb=refs%2Fchanges%2F59%2F47459%2F4;hp=e31d75f0773b5807e6afc0000392fb52446951aa;hpb=c9d61ee66367d819319bb8ccfa9f9b0555264d86;p=controller.git diff --git a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/TransactionCanCommitSuccess.java b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/TransactionCanCommitSuccess.java index e31d75f077..e6149bd5da 100644 --- a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/TransactionCanCommitSuccess.java +++ b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/TransactionCanCommitSuccess.java @@ -7,32 +7,25 @@ */ package org.opendaylight.controller.cluster.access.commands; -import akka.actor.ActorRef; -import com.google.common.base.Preconditions; import org.opendaylight.controller.cluster.access.ABIVersion; import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; /** - * Successful reply to a coordinated commit request. It contains a reference to the actor which is handling the commit - * process. + * Successful reply to a coordinated commit request initiated by a {@link ModifyTransactionRequest} + * or {@link CommitLocalTransactionRequest}. * * @author Robert Varga */ public final class TransactionCanCommitSuccess extends TransactionSuccess { private static final long serialVersionUID = 1L; - private final ActorRef cohort; - public TransactionCanCommitSuccess(final TransactionIdentifier identifier, final ActorRef cohort) { - super(identifier); - this.cohort = Preconditions.checkNotNull(cohort); - } - - public ActorRef getCohort() { - return cohort; + public TransactionCanCommitSuccess(final TransactionIdentifier identifier, final long sequence) { + super(identifier, sequence); } @Override - protected AbstractTransactionSuccessProxy externalizableProxy(final ABIVersion version) { + protected AbstractTransactionSuccessProxy externalizableProxy( + final ABIVersion version) { return new TransactionCanCommitSuccessProxyV1(this); }