private static TestActorRef<MessageCollectorActor> mockShardActor;
- private static String mockShardName;
+ private static ShardIdentifier mockShardName;
private final DatastoreContext.Builder datastoreContextBuilder = DatastoreContext.newBuilder().
dataStoreName(shardMrgIDSuffix).shardInitializationTimeout(600, TimeUnit.MILLISECONDS)
InMemorySnapshotStore.clear();
if(mockShardActor == null) {
- mockShardName = new ShardIdentifier(Shard.DEFAULT_NAME, "member-1", "config").toString();
- mockShardActor = TestActorRef.create(getSystem(), Props.create(MessageCollectorActor.class), mockShardName);
+ mockShardName = new ShardIdentifier(Shard.DEFAULT_NAME, "member-1", "config");
+ mockShardActor = TestActorRef.create(getSystem(), Props.create(MessageCollectorActor.class),
+ mockShardName.toString());
}
mockShardActor.underlyingActor().clear();
InMemoryJournal.addEntry(persistenceID, 2L, new SchemaContextModules(ImmutableSet.of("bar")));
InMemoryJournal.addDeleteMessagesCompleteLatch(persistenceID);
- TestShardManager shardManager = newTestShardManager();
+ newTestShardManager();
InMemoryJournal.waitForDeleteMessagesComplete(persistenceID);