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=55c5cdb2d61641d3cc2b3224c04a88feccde7708;hb=refs%2Fheads%2Fmaster;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..55c5cdb2d6 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,37 +7,34 @@ */ 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 { + @java.io.Serial 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); + private TransactionCanCommitSuccess(final TransactionCanCommitSuccess success, final ABIVersion version) { + super(success, version); } - public ActorRef getCohort() { - return cohort; + public TransactionCanCommitSuccess(final TransactionIdentifier identifier, final long sequence) { + super(identifier, sequence); } @Override - protected AbstractTransactionSuccessProxy externalizableProxy(final ABIVersion version) { - return new TransactionCanCommitSuccessProxyV1(this); + protected TCCS externalizableProxy(final ABIVersion version) { + return new TCCS(this); } @Override protected TransactionCanCommitSuccess cloneAsVersion(final ABIVersion version) { - return this; + return new TransactionCanCommitSuccess(this, version); } }