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;
shardActor.forward(new ForwardedCommitTransaction(cohort, modification),
getContext());
+ getContext().parent().tell(PoisonPill.getInstance(), getSelf());
+
}
private void preCommit(PreCommitTransaction message) {