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);
-
+ public void handleReceive(Object message) throws Exception {
if (message instanceof CanCommitTransaction) {
canCommit((CanCommitTransaction) message);
} else if (message instanceof PreCommitTransaction) {