X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FShardManagerGetSnapshotReplyActorTest.java;h=4bb00d262904926928d226f76001ac80648b759c;hb=9412c00daf7c8c3f108d1284a6288753ba67f6ac;hp=3052397c4f9d3bef760cf54790229b7775fb5725;hpb=357eb2684de759f296d1315e587308db5f1c54d4;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardManagerGetSnapshotReplyActorTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardManagerGetSnapshotReplyActorTest.java index 3052397c4f..4bb00d2629 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardManagerGetSnapshotReplyActorTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardManagerGetSnapshotReplyActorTest.java @@ -13,6 +13,7 @@ import akka.actor.ActorRef; import akka.actor.Status.Failure; import akka.actor.Terminated; import akka.testkit.JavaTestKit; +import java.util.Arrays; import java.util.List; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; @@ -44,7 +45,8 @@ public class ShardManagerGetSnapshotReplyActorTest extends AbstractActorTest { JavaTestKit kit = new JavaTestKit(getSystem()); byte[] shardManagerSnapshot = new byte[]{0,5,9}; - ActorRef replyActor = actorFactory.createActor(ShardManagerGetSnapshotReplyActor.props(3, "config", + 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")); @@ -85,7 +87,8 @@ public class ShardManagerGetSnapshotReplyActorTest extends AbstractActorTest { JavaTestKit kit = new JavaTestKit(getSystem()); byte[] shardManagerSnapshot = new byte[]{0,5,9}; - ActorRef replyActor = actorFactory.createActor(ShardManagerGetSnapshotReplyActor.props(2, "config", + ActorRef replyActor = actorFactory.createActor(ShardManagerGetSnapshotReplyActor.props( + Arrays.asList("shard1", "shard2"), "config", shardManagerSnapshot, kit.getRef(), "shard-manager", Duration.create(100, TimeUnit.SECONDS)), actorFactory.generateActorId("actor")); @@ -105,7 +108,8 @@ public class ShardManagerGetSnapshotReplyActorTest extends AbstractActorTest { JavaTestKit kit = new JavaTestKit(getSystem()); byte[] shardManagerSnapshot = new byte[]{0,5,9}; - ActorRef replyActor = actorFactory.createActor(ShardManagerGetSnapshotReplyActor.props(1, "config", + ActorRef replyActor = actorFactory.createActor(ShardManagerGetSnapshotReplyActor.props( + Arrays.asList("shard1"), "config", shardManagerSnapshot, kit.getRef(), "shard-manager", Duration.create(100, TimeUnit.MILLISECONDS)), actorFactory.generateActorId("actor"));