This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 6760e68c79bc36422bfb87979ef8fb95abb3ccb5 Author: James Netherton <[email protected]> AuthorDate: Thu Jun 25 11:59:14 2026 +0100 Adapt vertx-websocket to recent component changes --- .../quarkus/component/vertx/websocket/VertxWebsocketRecorder.java | 3 ++- .../quarkus/component/vertx/websocket/it/VertxWebsocketResource.java | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/extensions/vertx-websocket/runtime/src/main/java/org/apache/camel/quarkus/component/vertx/websocket/VertxWebsocketRecorder.java b/extensions/vertx-websocket/runtime/src/main/java/org/apache/camel/quarkus/component/vertx/websocket/VertxWebsocketRecorder.java index 846bef6197..fc1383f136 100644 --- a/extensions/vertx-websocket/runtime/src/main/java/org/apache/camel/quarkus/component/vertx/websocket/VertxWebsocketRecorder.java +++ b/extensions/vertx-websocket/runtime/src/main/java/org/apache/camel/quarkus/component/vertx/websocket/VertxWebsocketRecorder.java @@ -31,6 +31,7 @@ import io.quarkus.vertx.http.runtime.ServerSslConfig; import io.quarkus.vertx.http.runtime.VertxHttpConfig; import io.vertx.core.Vertx; import io.vertx.core.http.HttpClientOptions; +import io.vertx.core.http.WebSocketClientOptions; import io.vertx.core.http.WebSocketConnectOptions; import io.vertx.ext.web.Router; import org.apache.camel.CamelContext; @@ -138,7 +139,7 @@ public class VertxWebsocketRecorder { } @Override - public WebSocketConnectOptions getWebSocketConnectOptions(HttpClientOptions options) { + public WebSocketConnectOptions getWebSocketConnectOptions(WebSocketClientOptions options) { WebSocketConnectOptions connectOptions = super.getWebSocketConnectOptions(options); URI uri = URI.create(getEndpointUri().replaceFirst("wss?:/*", "")); if (ObjectHelper.isNotEmpty(uri.getHost()) && uri.getPort() == -1) { diff --git a/integration-tests/vertx-websocket/src/main/java/org/apache/camel/quarkus/component/vertx/websocket/it/VertxWebsocketResource.java b/integration-tests/vertx-websocket/src/main/java/org/apache/camel/quarkus/component/vertx/websocket/it/VertxWebsocketResource.java index f45c817d96..e73037c3ba 100644 --- a/integration-tests/vertx-websocket/src/main/java/org/apache/camel/quarkus/component/vertx/websocket/it/VertxWebsocketResource.java +++ b/integration-tests/vertx-websocket/src/main/java/org/apache/camel/quarkus/component/vertx/websocket/it/VertxWebsocketResource.java @@ -21,7 +21,7 @@ import java.util.List; import java.util.Map; import java.util.StringJoiner; -import io.vertx.core.http.HttpClientOptions; +import io.vertx.core.http.WebSocketClientOptions; import io.vertx.core.http.WebSocketConnectOptions; import jakarta.enterprise.context.ApplicationScoped; import jakarta.inject.Inject; @@ -120,7 +120,7 @@ public class VertxWebsocketResource { String uri = "vertx-websocket:" + scheme + "localhost/test"; VertxWebsocketRecorder.QuarkusVertxWebsocketEndpoint endpoint = context.getEndpoint(uri, VertxWebsocketRecorder.QuarkusVertxWebsocketEndpoint.class); - WebSocketConnectOptions connectOptions = endpoint.getWebSocketConnectOptions(new HttpClientOptions()); + WebSocketConnectOptions connectOptions = endpoint.getWebSocketConnectOptions(new WebSocketClientOptions()); return connectOptions.getPort(); }
