- byte[] shardManagerSnapshot = new byte[]{0,5,9};
- ActorRef replyActor = actorFactory.createActor(ShardManagerGetSnapshotReplyActor.props(
- Arrays.asList("shard1", "shard2", "shard3"), "config",
- shardManagerSnapshot, kit.getRef(), "shard-manager", Duration.create(100, TimeUnit.SECONDS)),
- actorFactory.generateActorId("actor"));
+ List<String> shardList = Arrays.asList("shard1", "shard2", "shard3");
+ ShardManagerSnapshot shardManagerSnapshot = new ShardManagerSnapshot(shardList, Collections.emptyMap());
+ ActorRef replyActor = getSystem().actorOf(ShardManagerGetSnapshotReplyActor.props(
+ shardList, "config", shardManagerSnapshot, kit.getRef(),
+ "shard-manager", FiniteDuration.create(100, TimeUnit.SECONDS)), "testSuccess");