NetconfClientFactoryImpl should propagate stack failure

[netconf.git] / protocol / netconf-client / src / main / java / org / opendaylight / netconf / client / NetconfClientFactoryImpl.java

diff --git a/protocol/netconf-client/src/main/java/org/opendaylight/netconf/client/NetconfClientFactoryImpl.java b/protocol/netconf-client/src/main/java/org/opendaylight/netconf/client/NetconfClientFactoryImpl.java
index 940da73b68ae2b736964e52dfe68cdf8573d81a7..66714af59d654ddc518cd1f301f60b58db4ca285 100644 (file)
--- a/protocol/netconf-client/src/main/java/org/opendaylight/netconf/client/NetconfClientFactoryImpl.java
+++ b/protocol/netconf-client/src/main/java/org/opendaylight/netconf/client/NetconfClientFactoryImpl.java
@@ -10,7 +10,9 @@ package org.opendaylight.netconf.client;
 import static java.util.Objects.requireNonNull;
 
 import com.google.common.collect.ImmutableSet;
+import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
 import javax.annotation.PreDestroy;
 import javax.inject.Inject;
 import javax.inject.Singleton;
@@ -28,14 +30,10 @@ import org.osgi.service.component.annotations.Activate;
 import org.osgi.service.component.annotations.Component;
 import org.osgi.service.component.annotations.Deactivate;
 import org.osgi.service.component.annotations.Reference;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 @Singleton
 @Component(service = NetconfClientFactory.class)
 public final class NetconfClientFactoryImpl implements NetconfClientFactory {
-    private static final Logger LOG = LoggerFactory.getLogger(NetconfClientFactoryImpl.class);
-
     private final SSHTransportStackFactory factory;
     private final NetconfTimer timer;
 
@@ -78,7 +76,7 @@ public final class NetconfClientFactoryImpl implements NetconfClientFactory {
                     handlerFactory);
             }
         };
-        LOG.trace("Future stack is {}", stackFuture);
+        Futures.addCallback(stackFuture, transportListener, MoreExecutors.directExecutor());
 
         return transportListener.sessionFuture();
     }