X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;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=c6744a9393faf96a0a8e643e7258b03516ee3c59;hp=38e0596a07a30028b38877283638d9f678482815;hb=d97061af6814ad7b085af10797a252aa4aa5cda6;hpb=bc5486e6d9fab8f550be8b72874ce96a9eb52651 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..c6744a9393 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 @@ -23,10 +23,10 @@ public class YnlListener implements OdlMdsalLowlevelTargetListener { 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); @@ -42,14 +42,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; + }); } }