X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fnetconf-netty-util%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fnettyutil%2Fhandler%2Fssh%2Fclient%2FNetconfSshClient.java;fp=netconf%2Fnetconf-netty-util%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fnettyutil%2Fhandler%2Fssh%2Fclient%2FNetconfSshClient.java;h=b4f318ebd25e2785baf5c388a1bd89ba0ad41ba0;hb=4e9c87babd30222032fb0ba3ea9eb999141a8fa3;hp=d5d0d97aa955636191257b0ef4e8e792fbb1a9ae;hpb=afbc1e06f36172f790654d834ef55ac216bbfb40;p=netconf.git

diff --git a/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/handler/ssh/client/NetconfSshClient.java b/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/handler/ssh/client/NetconfSshClient.java
index d5d0d97aa9..b4f318ebd2 100644
--- a/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/handler/ssh/client/NetconfSshClient.java
+++ b/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/handler/ssh/client/NetconfSshClient.java
@@ -8,8 +8,11 @@
 package org.opendaylight.netconf.nettyutil.handler.ssh.client;
 
 import com.google.common.annotations.Beta;
+import org.opendaylight.netconf.nettyutil.handler.ssh.sshd1028.NetconfNio2ServiceFactoryFactory;
 import org.opendaylight.netconf.shaded.sshd.client.SshClient;
 import org.opendaylight.netconf.shaded.sshd.common.Factory;
+import org.opendaylight.netconf.shaded.sshd.common.io.IoConnector;
+
 
 /**
  * An extension to {@link SshClient} which uses {@link NetconfSessionFactory} to create sessions (leading towards
@@ -18,9 +21,20 @@ import org.opendaylight.netconf.shaded.sshd.common.Factory;
 @Beta
 public class NetconfSshClient extends SshClient {
     public static final Factory<SshClient> DEFAULT_NETCONF_SSH_CLIENT_FACTORY = NetconfSshClient::new;
+    private final NetconfNio2ServiceFactoryFactory nio2ServiceFactoryFactory;
+
+    public NetconfSshClient() {
+        this.nio2ServiceFactoryFactory = new NetconfNio2ServiceFactoryFactory();
+    }
 
     @Override
     protected NetconfSessionFactory createSessionFactory() {
         return new NetconfSessionFactory(this);
     }
+
+    @Override
+    protected IoConnector createConnector() {
+        setIoServiceFactoryFactory(nio2ServiceFactoryFactory);
+        return getIoServiceFactory().createConnector(getSessionFactory());
+    }
 }