X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2Fregistry%2Fgossip%2FGossiper.java;h=f597c316e5cdfda042fef8f6ea12741a905b20cf;hp=e45950d1cae329d225cac3a9d51943fb1e716f8c;hb=1a4a451d17d39b0dac45a70de9016bd4b0e6b249;hpb=cf434f30a13bde72c33799e33de39fae5e62a773 diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/Gossiper.java b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/Gossiper.java index e45950d1ca..f597c316e5 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/Gossiper.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/Gossiper.java @@ -18,6 +18,7 @@ import akka.cluster.ClusterEvent; import akka.cluster.Member; import akka.dispatch.Mapper; import akka.pattern.Patterns; +import com.google.common.base.Preconditions; import java.util.ArrayList; import java.util.HashSet; import java.util.List; @@ -77,10 +78,10 @@ public class Gossiper extends AbstractUntypedActorWithMetering { private Boolean autoStartGossipTicks = true; - private RemoteRpcProviderConfig config; + private final RemoteRpcProviderConfig config; - public Gossiper(){ - config = new RemoteRpcProviderConfig(getContext().system().settings().config()); + public Gossiper(RemoteRpcProviderConfig config){ + this.config = Preconditions.checkNotNull(config); } /** @@ -88,7 +89,8 @@ public class Gossiper extends AbstractUntypedActorWithMetering { * @param autoStartGossipTicks used for turning off gossip ticks during testing. * Gossip tick can be manually sent. */ - public Gossiper(Boolean autoStartGossipTicks){ + public Gossiper(Boolean autoStartGossipTicks, RemoteRpcProviderConfig config){ + this(config); this.autoStartGossipTicks = autoStartGossipTicks; }