package org.opendaylight.controller.cluster.datastore;
import akka.actor.ActorRef;
+import akka.actor.PoisonPill;
import akka.actor.Props;
-import akka.actor.UntypedActor;
import akka.event.Logging;
import akka.event.LoggingAdapter;
import akka.japi.Creator;
import java.util.concurrent.ExecutionException;
-public class ThreePhaseCommitCohort extends UntypedActor {
+public class ThreePhaseCommitCohort extends AbstractUntypedActor {
private final DOMStoreThreePhaseCommitCohort cohort;
private final ActorRef shardActor;
private final CompositeModification modification;
});
}
- @Override
- public void onReceive(Object message) throws Exception {
- log.debug("Received message {}", message);
+ @Override
+ public void handleReceive(Object message) throws Exception {
if (message instanceof CanCommitTransaction) {
canCommit((CanCommitTransaction) message);
} else if (message instanceof PreCommitTransaction) {
shardActor.forward(new ForwardedCommitTransaction(cohort, modification),
getContext());
+ getContext().parent().tell(PoisonPill.getInstance(), getSelf());
+
}
private void preCommit(PreCommitTransaction message) {