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%2FBucketStore.java;h=d349035b3c62f40743ca7fd8da898d39b6bce147;hp=febff0bc92efc4c8ad896a92e3d367156c6fd345;hb=refs%2Fchanges%2F62%2F27562%2F9;hpb=cf434f30a13bde72c33799e33de39fae5e62a773 diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/BucketStore.java b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/BucketStore.java index febff0bc92..d349035b3c 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/BucketStore.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/gossip/BucketStore.java @@ -13,6 +13,7 @@ import akka.actor.ActorRefProvider; import akka.actor.Address; import akka.actor.Props; import akka.cluster.ClusterActorRefProvider; +import com.google.common.base.Preconditions; import java.util.HashMap; import java.util.Map; import java.util.Set; @@ -68,8 +69,8 @@ public class BucketStore> extends AbstractUntypedActorWithMe private final RemoteRpcProviderConfig config; - public BucketStore(){ - config = new RemoteRpcProviderConfig(getContext().system().settings().config()); + public BucketStore(RemoteRpcProviderConfig config){ + this.config = Preconditions.checkNotNull(config); } @Override @@ -78,7 +79,7 @@ public class BucketStore> extends AbstractUntypedActorWithMe selfAddress = provider.getDefaultAddress(); if ( provider instanceof ClusterActorRefProvider) { - getContext().actorOf(Props.create(Gossiper.class).withMailbox(config.getMailBoxName()), "gossiper"); + getContext().actorOf(Props.create(Gossiper.class, config).withMailbox(config.getMailBoxName()), "gossiper"); } }