import akka.actor.Status;
import akka.actor.Status.Failure;
import akka.actor.Status.Success;
-import akka.actor.Terminated;
import akka.cluster.Cluster;
import akka.cluster.ClusterEvent;
import akka.dispatch.Dispatchers;
TestActorRef<TestShardManager> shardManager = actorFactory.createTestActor(
newTestShardMgrBuilder(mockConfig).addShardActor("default", shard).props());
- watch(shard);
-
shardManager.underlyingActor().waitForRecoveryComplete();
shardManager.tell(new UpdateSchemaContext(TestModel.createTestContext()), getRef());
shardManager.underlyingActor().verifySnapshotPersisted(Sets.newHashSet("people"));
- expectMsgClass(duration("5 seconds"), Terminated.class);
+ MessageCollectorActor.expectFirstMatching(shard, Shutdown.class);
}};
LOG.info("testServerRemovedShardActorRunning ending");