import akka.event.Logging;
import akka.event.LoggingAdapter;
import akka.japi.Creator;
import akka.event.Logging;
import akka.event.LoggingAdapter;
import akka.japi.Creator;
if (message instanceof ReadData) {
readData((ReadData) message);
} else if (message instanceof WriteData) {
if (message instanceof ReadData) {
readData((ReadData) message);
} else if (message instanceof WriteData) {
private void readyTransaction(ReadyTransaction message) {
DOMStoreThreePhaseCommitCohort cohort = transaction.ready();
ActorRef cohortActor = getContext().actorOf(
private void readyTransaction(ReadyTransaction message) {
DOMStoreThreePhaseCommitCohort cohort = transaction.ready();
ActorRef cohortActor = getContext().actorOf(
- ThreePhaseCommitCohort.props(cohort, shardActor, modification));
+ ThreePhaseCommitCohort.props(cohort, shardActor, modification), "cohort");