Fix a sonar complaint 88/94188/2
authorRobert Varga <robert.varga@pantheon.tech>
Fri, 11 Dec 2020 02:41:24 +0000 (03:41 +0100)
committerRobert Varga <robert.varga@pantheon.tech>
Fri, 11 Dec 2020 07:43:38 +0000 (08:43 +0100)
Sonar wants us to merge the two if statements, which makes sense.
Also use a method reference instead of a full lambda.

Change-Id: I465ab536ab9b5bedde870b741a47becbc271ca8b
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
replicate/mdsal-replicate-netty/src/main/java/org/opendaylight/mdsal/replicate/netty/SinkSingletonService.java

index 98e154e3d8f7a6f58983474d4552c7316c09f3d0..02aa97eb3c9b8b7e24593345a85c5c6cc33b1e53 100644 (file)
@@ -170,14 +170,10 @@ final class SinkSingletonService extends ChannelInitializer<SocketChannel> imple
     }
 
     private synchronized void channelClosed(final ChannelFuture completedFuture, final ScheduledExecutorService group) {
-        if (futureChannel != null && futureChannel.channel() == completedFuture.channel()) {
-            if (!closingInstance) {
-                LOG.info("Channel {} lost connection to source {}, reconnecting in {}", completedFuture.channel(),
-                    sourceAddress, reconnectDelay.getSeconds());
-                group.schedule(() -> {
-                    reconnect();
-                }, reconnectDelay.toNanos(), TimeUnit.NANOSECONDS);
-            }
+        if (futureChannel != null && futureChannel.channel() == completedFuture.channel() && !closingInstance) {
+            LOG.info("Channel {} lost connection to source {}, reconnecting in {}", completedFuture.channel(),
+                sourceAddress, reconnectDelay.getSeconds());
+            group.schedule(this::reconnect, reconnectDelay.toNanos(), TimeUnit.NANOSECONDS);
         }
     }