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;fp=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2Fregistry%2Fgossip%2FGossiper.java;h=f43a1d9f9613e3871c6190948c12fb7f7172e1e0;hp=e75bef24c7aa22e7758b430a6ca9aeba31f8f381;hb=3859df9beca8f13f1ff2b2744ed3470a1715bec3;hpb=083a04543a96ae862c48ccb4aaefc667f19d9f1e;ds=sidebyside 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 e75bef24c7..f43a1d9f96 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 @@ -7,6 +7,9 @@ */ package org.opendaylight.controller.remote.rpc.registry.gossip; +import static com.google.common.base.Verify.verifyNotNull; +import static java.util.Objects.requireNonNull; + import akka.actor.ActorRef; import akka.actor.ActorRefProvider; import akka.actor.ActorSelection; @@ -18,8 +21,6 @@ import akka.cluster.ClusterActorRefProvider; import akka.cluster.ClusterEvent; import akka.cluster.Member; import com.google.common.annotations.VisibleForTesting; -import com.google.common.base.Preconditions; -import com.google.common.base.Verify; import com.google.common.collect.Maps; import java.util.ArrayList; import java.util.HashMap; @@ -85,7 +86,7 @@ public class Gossiper extends AbstractUntypedActorWithMetering { private BucketStoreAccess bucketStore; Gossiper(final RemoteOpsProviderConfig config, final Boolean autoStartGossipTicks) { - this.config = Preconditions.checkNotNull(config); + this.config = requireNonNull(config); this.autoStartGossipTicks = autoStartGossipTicks.booleanValue(); } @@ -243,7 +244,7 @@ public class Gossiper extends AbstractUntypedActorWithMetering { } LOG.trace("Gossiping to [{}]", address); - getLocalStatusAndSendTo(Verify.verifyNotNull(peers.get(address))); + getLocalStatusAndSendTo(verifyNotNull(peers.get(address))); } /**