FIX: Netty: call onDisconnect when crossbar not reachable (#418)

* FIX: Netty: call onDisconnect when crossbar not reachable

Author: om26er

autobahn/src/main/java/io/crossbar/autobahn/wamp/Client.java

@@ -127,7 +127,7 @@ public CompletableFuture<ExitInfo> connect(TransportOptions options) {
             try {
                 mTransports.get(0).connect(mSession, options);
             } catch (Exception e) {
-                throw new CompletionException(e);
+                exitFuture.completeExceptionally(e);
             }
         }, getExecutor());
         return exitFuture;

autobahn/src/main/java/io/crossbar/autobahn/wamp/transports/NettyWebSocket.java

@@ -31,6 +31,8 @@
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
 import io.netty.channel.Channel;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelInitializer;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.EventLoopGroup;
@@ -178,9 +180,15 @@ protected void initChannel(SocketChannel ch) throws Exception {
                         mHandler);
             }
         });
-
-        mChannel = bootstrap.connect(uri.getHost(), port).sync().channel();
-        mHandler.getHandshakeFuture().sync();
+        ChannelFuture f = bootstrap.connect(uri.getHost(), port);
+        f.addListener((ChannelFutureListener) connectFuture -> {
+            Throwable connectCause = connectFuture.cause();
+            if (connectCause != null) {
+                transportHandler.onDisconnect(false);
+            } else {
+                mChannel = f.channel();
+            }
+        });
     }
 
     @Override