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;
});
}
+
@Override
public void onReceive(Object message) throws Exception {
log.debug("Received message {}", message);
shardActor.forward(new ForwardedCommitTransaction(cohort, modification),
getContext());
+ getContext().parent().tell(PoisonPill.getInstance(), getSelf());
+
}
private void preCommit(PreCommitTransaction message) {