X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsamples%2Fclustering-test-app%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fit%2Fprovider%2Fimpl%2FYnlListener.java;h=331ee91850dc69d3aa4aa98ccda17f7d42403fa9;hb=da174be7e22b16d4ac80cccefdc52b209b700745;hp=38e0596a07a30028b38877283638d9f678482815;hpb=9c17a104cd90b5529b5623d1d0136d7cc332707d;p=controller.git diff --git a/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/impl/YnlListener.java b/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/impl/YnlListener.java index 38e0596a07..331ee91850 100644 --- a/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/impl/YnlListener.java +++ b/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/impl/YnlListener.java @@ -5,10 +5,10 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.controller.clustering.it.provider.impl; -import com.google.common.base.Preconditions; +import static java.util.Objects.requireNonNull; + import java.util.concurrent.atomic.AtomicLong; import org.opendaylight.yang.gen.v1.tag.opendaylight.org._2017.controller.yang.lowlevel.control.rev170215.UnsubscribeYnlOutput; import org.opendaylight.yang.gen.v1.tag.opendaylight.org._2017.controller.yang.lowlevel.control.rev170215.UnsubscribeYnlOutputBuilder; @@ -18,19 +18,17 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class YnlListener implements OdlMdsalLowlevelTargetListener { - private static final Logger LOG = LoggerFactory.getLogger(YnlListener.class); private final String id; - private AtomicLong localNumber = new AtomicLong(); - private AtomicLong allNot = new AtomicLong(); - private AtomicLong idNot = new AtomicLong(); - private AtomicLong errNot = new AtomicLong(); + private final AtomicLong localNumber = new AtomicLong(); + private final AtomicLong allNot = new AtomicLong(); + private final AtomicLong idNot = new AtomicLong(); + private final AtomicLong errNot = new AtomicLong(); public YnlListener(final String id) { - Preconditions.checkNotNull(id); - this.id = id; + this.id = requireNonNull(id); } @Override @@ -42,14 +40,13 @@ public class YnlListener implements OdlMdsalLowlevelTargetListener { if (notification.getId().equals(id)) { idNot.incrementAndGet(); - localNumber.getAndUpdate((value -> { + localNumber.getAndUpdate(value -> { if (notification.getSequenceNumber() - value == 1) { return value + 1; - } else { - errNot.getAndIncrement(); - return value; } - })); + errNot.getAndIncrement(); + return value; + }); } }