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%2Futils%2FMockClusterWrapper.java;h=fe40aa0fd4571c65f431124d3b58704b9b62b9c6;hb=1e25f44b70aab9998f33b2136a0cf628821cd2dc;hp=b80506d17d2efa61f5ae5673d3687dc67501bdee;hpb=c36bb2bc93ea0fbdd3ca8b2663447fc921450aee;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/MockClusterWrapper.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/MockClusterWrapper.java index b80506d17d..fe40aa0fd4 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/MockClusterWrapper.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/MockClusterWrapper.java @@ -9,6 +9,7 @@ package org.opendaylight.controller.cluster.datastore.utils; import akka.actor.ActorRef; +import akka.actor.Address; import akka.actor.AddressFromURIString; import akka.cluster.ClusterEvent; import akka.cluster.MemberStatus; @@ -20,7 +21,7 @@ import java.util.Set; public class MockClusterWrapper implements ClusterWrapper{ - private String selfAddress = "akka.tcp://test@127.0.0.1:2550/user/member-1-shard-test-config"; + private Address selfAddress = new Address("akka.tcp", "test", "127.0.0.1", 2550); @Override public void subscribeToMemberEvents(ActorRef actorRef) { @@ -32,11 +33,11 @@ public class MockClusterWrapper implements ClusterWrapper{ } @Override - public String getSelfAddress() { + public Address getSelfAddress() { return selfAddress; } - public void setSelfAddress(String selfAddress) { + public void setSelfAddress(Address selfAddress) { this.selfAddress = selfAddress; }