X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;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=7dc4b19039d641bba637e84a9ea63313f6bca00d;hpb=e4a1f1fa1f3efb4442c1141224b8a2df714efcb4;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 7dc4b19039..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,33 +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 long sequence, final long retry, - final ActorRef cohort) { - super(identifier, sequence, retry); - 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); }