(camel-quarkus-examples) 01/02: Fix deprecated API usage in vertx-websocket-chat tests

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch camel-quarkus-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus-examples.git

commit 94a4eedbf2629e0b4cfc2a68136b140336588709
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Wed Sep 4 13:59:03 2024 +0100

    Fix deprecated API usage in vertx-websocket-chat tests
---
 .../test/java/org/acme/websocket/WebSocketRoutesTest.java  | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git 
a/vertx-websocket-chat/src/test/java/org/acme/websocket/WebSocketRoutesTest.java
 
b/vertx-websocket-chat/src/test/java/org/acme/websocket/WebSocketRoutesTest.java
index efd630d..aab13bc 100644
--- 
a/vertx-websocket-chat/src/test/java/org/acme/websocket/WebSocketRoutesTest.java
+++ 
b/vertx-websocket-chat/src/test/java/org/acme/websocket/WebSocketRoutesTest.java
@@ -25,10 +25,12 @@ import io.quarkus.test.common.http.TestHTTPResource;
 import io.quarkus.test.junit.QuarkusTest;
 import io.vertx.core.Vertx;
 import io.vertx.core.buffer.Buffer;
-import io.vertx.core.http.HttpClient;
 import io.vertx.core.http.WebSocket;
+import io.vertx.core.http.WebSocketClient;
 import org.junit.jupiter.api.Test;
 
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
 @QuarkusTest
 public class WebSocketRoutesTest {
     @TestHTTPResource("/chat/bob")
@@ -43,21 +45,21 @@ public class WebSocketRoutesTest {
         CountDownLatch messageLatch = new CountDownLatch(2);
 
         Vertx vertx = Vertx.vertx();
-        HttpClient client = vertx.createHttpClient();
+        WebSocketClient client = vertx.createWebSocketClient();
         try {
             AtomicReference<WebSocket> bobWebSocketAtomicReference = new 
AtomicReference<>();
-            client.webSocket(userBob.getPort(), userBob.getHost(), 
userBob.getPath()).onSuccess(webSocket -> {
+            client.connect(userBob.getPort(), userBob.getHost(), 
userBob.getPath()).onSuccess(webSocket -> {
                 bobWebSocketAtomicReference.set(webSocket);
                 connectLatch.countDown();
             });
 
             AtomicReference<WebSocket> amyWebSocketAtomicReference = new 
AtomicReference<>();
-            client.webSocket(userAmy.getPort(), userAmy.getHost(), 
userAmy.getPath()).onSuccess(webSocket -> {
+            client.connect(userAmy.getPort(), userAmy.getHost(), 
userAmy.getPath()).onSuccess(webSocket -> {
                 amyWebSocketAtomicReference.set(webSocket);
                 connectLatch.countDown();
             });
 
-            connectLatch.await(5, TimeUnit.SECONDS);
+            assertTrue(connectLatch.await(5, TimeUnit.SECONDS));
 
             WebSocket bobWebSocket = bobWebSocketAtomicReference.get();
             bobWebSocket.handler(message -> {
@@ -76,7 +78,7 @@ public class WebSocketRoutesTest {
             bobWebSocket.write(Buffer.buffer("Hi Amy"));
             amyWebSocket.write(Buffer.buffer("Hi Bob"));
 
-            messageLatch.await(5, TimeUnit.SECONDS);
+            assertTrue(messageLatch.await(5, TimeUnit.SECONDS));
         } finally {
             if (client != null) {
                 client.close();