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%2Fshardmanager%2FShardPeerAddressResolverTest.java;h=0c18e799a5092a73bb266c26f6065eff021ce92b;hb=1ffd1f44c4beacdb28683c028bc0eaa209731098;hp=c735d9dfd4e0e416c09d1ae24988f2116e6ae5e8;hpb=99edecc3eabbe743fd586e7ab26bcc61365ff6da;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardPeerAddressResolverTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardPeerAddressResolverTest.java index c735d9dfd4..0c18e799a5 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardPeerAddressResolverTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardPeerAddressResolverTest.java @@ -80,6 +80,21 @@ public class ShardPeerAddressResolverTest { assertEquals("resolve", shardAddress, resolver.resolve(peerId)); } + @Test + public void testSetResolved() { + String type = "config"; + ShardPeerAddressResolver resolver = new ShardPeerAddressResolver(type, MEMBER_1); + + String peerId = ShardIdentifier.create("default", MEMBER_2, type).toString(); + + String address = "akka.tcp://opendaylight-cluster-data@127.0.0.1:2550/user/shardmanager-" + type + + "/" + MEMBER_2.getName() + "-shard-default-" + type; + + resolver.setResolved(peerId, address); + + assertEquals("resolve", address, resolver.resolve(peerId)); + } + @Test public void testGetShardManagerPeerActorAddresses() { ShardPeerAddressResolver resolver = new ShardPeerAddressResolver("config", MEMBER_1);