import akka.actor.Props;
import akka.actor.Status;
import com.google.common.base.Preconditions;
+import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
import org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor;
import org.opendaylight.mdsal.common.api.PostCanCommitStep;
import org.opendaylight.mdsal.common.api.PostPreCommitStep;
*/
static abstract class CommitProtocolCommand<R extends CommitReply> {
- private final String txId;
+ private final TransactionIdentifier txId;
- final String getTxId() {
+ final TransactionIdentifier getTxId() {
return txId;
}
- protected CommitProtocolCommand(String txId) {
+ protected CommitProtocolCommand(TransactionIdentifier txId) {
this.txId = Preconditions.checkNotNull(txId);
}
}
private final ActorRef cohort;
private final SchemaContext schema;
- CanCommit(String txId, DOMDataTreeCandidate candidate, SchemaContext schema, ActorRef cohort) {
+ CanCommit(TransactionIdentifier txId, DOMDataTreeCandidate candidate, SchemaContext schema, ActorRef cohort) {
super(txId);
this.cohort = Preconditions.checkNotNull(cohort);
this.candidate = Preconditions.checkNotNull(candidate);
static abstract class CommitReply {
private final ActorRef cohortRef;
- private final String txId;
+ private final TransactionIdentifier txId;
- protected CommitReply(ActorRef cohortRef, String txId) {
+ protected CommitReply(ActorRef cohortRef, TransactionIdentifier txId) {
this.cohortRef = Preconditions.checkNotNull(cohortRef);
this.txId = Preconditions.checkNotNull(txId);
}
return cohortRef;
}
- final String getTxId() {
+ final TransactionIdentifier getTxId() {
return txId;
}
-
}
static final class Success extends CommitReply {
- public Success(ActorRef cohortRef, String txId) {
+ public Success(ActorRef cohortRef, TransactionIdentifier txId) {
super(cohortRef, txId);
}
static final class PreCommit extends CommitProtocolCommand<Success> {
- public PreCommit(String txId) {
+ public PreCommit(TransactionIdentifier txId) {
super(txId);
}
}
static final class Abort extends CommitProtocolCommand<Success> {
- public Abort(String txId) {
+ public Abort(TransactionIdentifier txId) {
super(txId);
}
}
static final class Commit extends CommitProtocolCommand<Success> {
- public Commit(String txId) {
+ public Commit(TransactionIdentifier txId) {
super(txId);
}
}
extends CohortBehaviour<M> {
private final S step;
- private final String txId;
+ private final TransactionIdentifier txId;
- CohortStateWithStep(String txId, S step) {
+ CohortStateWithStep(TransactionIdentifier txId, S step) {
this.txId = Preconditions.checkNotNull(txId);
this.step = Preconditions.checkNotNull(step);
}
return step;
}
- final String getTxId() {
+ final TransactionIdentifier getTxId() {
return txId;
}
private class PostCanCommit extends CohortStateWithStep<PreCommit, PostCanCommitStep> {
- PostCanCommit(String txId, PostCanCommitStep nextStep) {
+ PostCanCommit(TransactionIdentifier txId, PostCanCommitStep nextStep) {
super(txId, nextStep);
}
private class PostPreCommit extends CohortStateWithStep<Commit, PostPreCommitStep> {
- PostPreCommit(String txId, PostPreCommitStep step) {
+ PostPreCommit(TransactionIdentifier txId, PostPreCommitStep step) {
super(txId, step);
}