SCB-2099 Solve the problem of watch fail

apache · Oct 26, 2020 · fe58dbc · fe58dbc
1 parent d4e2a7c
commit fe58dbc
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...stry/src/main/java/org/apache/servicecomb/serviceregistry/client/http/WebsocketUtils.java b/...stry/src/main/java/org/apache/servicecomb/serviceregistry/client/http/WebsocketUtils.java
@@ -27,6 +27,7 @@
 import io.vertx.core.Handler;
 import io.vertx.core.buffer.Buffer;
 import io.vertx.core.http.HttpMethod;
+import io.vertx.core.http.WebSocket;
 import io.vertx.core.http.WebSocketConnectOptions;
 
 /**
@@ -52,18 +53,19 @@ public static void open(IpPort ipPort, String url, Handler<Void> onOpen, Handler
           onConnectFailed.handle(asyncResult.cause());
         } else {
           onOpen.handle(null);
-          asyncResult.result().exceptionHandler(v -> {
+          WebSocket webSocket = asyncResult.result();
+          webSocket.exceptionHandler(v -> {
             onException.handle(v);
             try {
               asyncResult.result().close();
             } catch (Exception err) {
               LOGGER.error("ws close error.", err);
             }
           });
-          asyncResult.result().closeHandler(v -> {
+          webSocket.closeHandler(v -> {
             onClose.handle(v);
           });
-          asyncResult.result().pongHandler(pong -> {
+          webSocket.pongHandler(pong -> {
             // ignore, just prevent NPE.
           });
           asyncResult.result().frameHandler((frame) -> onMessage.handle(frame.binaryData()));