From bc7fa16647968fcbc856816b02c31df93c587caa Mon Sep 17 00:00:00 2001 From: Robert Varga Date: Wed, 1 Jun 2022 18:47:56 +0200 Subject: [PATCH] Fix a raw type warning Use a FutureListener instead of a raw GenericFutureListener. Change-Id: Ie378ee8e7c3b38f781f48cc4ee6857834a14adc9 Signed-off-by: Robert Varga (cherry picked from commit 6e662cfa5ed236a16ae47e4917fe6f847e0a9598) (cherry picked from commit 3bdbc61d3a810a9f4623f7957832eab0afcc884a) --- .../nettyutil/handler/ssh/client/AsyncSshHandler.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/handler/ssh/client/AsyncSshHandler.java b/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/handler/ssh/client/AsyncSshHandler.java index 1c89e7761c..412ee2ca1a 100644 --- a/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/handler/ssh/client/AsyncSshHandler.java +++ b/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/handler/ssh/client/AsyncSshHandler.java @@ -14,7 +14,7 @@ import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelOutboundHandlerAdapter; import io.netty.channel.ChannelPromise; import io.netty.util.concurrent.Future; -import io.netty.util.concurrent.GenericFutureListener; +import io.netty.util.concurrent.FutureListener; import java.io.IOException; import java.net.SocketAddress; import java.util.concurrent.TimeUnit; @@ -65,7 +65,7 @@ public class AsyncSshHandler extends ChannelOutboundHandlerAdapter { private NettyAwareChannelSubsystem channel; private ClientSession session; private ChannelPromise connectPromise; - private GenericFutureListener negotiationFutureListener; + private FutureListener negotiationFutureListener; public AsyncSshHandler(final AuthenticationHandler authenticationHandler, final NetconfSshClient sshClient, final Future negotiationFuture) { @@ -189,8 +189,8 @@ public class AsyncSshHandler extends ChannelOutboundHandlerAdapter { @Override public synchronized void connect(final ChannelHandlerContext ctx, final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise) throws Exception { - LOG.debug("SSH session connecting on channel {}. promise: {} ", ctx.channel(), connectPromise); - this.connectPromise = promise; + LOG.debug("SSH session connecting on channel {}. promise: {}", ctx.channel(), connectPromise); + connectPromise = promise; if (negotiationFuture != null) { negotiationFutureListener = future -> { -- 2.36.6