import static org.junit.Assert.fail;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
-import akka.actor.PoisonPill;
import akka.cluster.Cluster;
import akka.cluster.ClusterEvent.CurrentClusterState;
import akka.cluster.Member;
cohort.commit().get(5, TimeUnit.SECONDS);
}
- public void cleanup(DistributedDataStore dataStore) {
- if(dataStore != null) {
- dataStore.getActorContext().getShardManager().tell(PoisonPill.getInstance(), null);
- }
- }
-
void assertExceptionOnCall(Callable<Void> callable, Class<? extends Exception> expType)
throws Exception {
try {