This is an automated email from the ASF dual-hosted git repository.
apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new e004ac0c509c Replace the non-breaking deprecated API from Vert.x
e004ac0c509c is described below
commit e004ac0c509cb8a096919401f8bfcd27b965cdc1
Author: Aurélien Pupier <[email protected]>
AuthorDate: Fri May 29 14:10:57 2026 +0200
Replace the non-breaking deprecated API from Vert.x
Signed-off-by: Aurélien Pupier <[email protected]>
---
.../org/apache/camel/component/vertx/http/VertxHttpEndpoint.java | 2 +-
.../apache/camel/component/vertx/websocket/VertxWebsocketHost.java | 2 +-
.../camel/component/vertx/websocket/VertxWebSocketTestSupport.java | 6 +++---
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/components/camel-vertx/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpEndpoint.java
b/components/camel-vertx/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpEndpoint.java
index d434da58861e..4da417868706 100644
---
a/components/camel-vertx/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpEndpoint.java
+++
b/components/camel-vertx/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpEndpoint.java
@@ -108,7 +108,7 @@ public class VertxHttpEndpoint extends DefaultEndpoint
implements EndpointServic
WebClientOptions options = configuration.getWebClientOptions();
if (options == null) {
options = new WebClientOptions();
- options.setTryUseCompression(configuration.isUseCompression());
+
options.setDecompressionSupported(configuration.isUseCompression());
options.setConnectTimeout(configuration.getConnectTimeout());
if (configuration.getTracingPolicy() != null) {
diff --git
a/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketHost.java
b/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketHost.java
index 91b465cc7b34..a3222fa81256 100644
---
a/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketHost.java
+++
b/components/camel-vertx/camel-vertx-websocket/src/main/java/org/apache/camel/component/vertx/websocket/VertxWebsocketHost.java
@@ -80,7 +80,7 @@ public class VertxWebsocketHost {
LOG.info("Connected consumer for path {}", path);
if (!ObjectHelper.isEmpty(configuration.getAllowedOriginPattern())) {
- CorsHandler corsHandler =
CorsHandler.create().addRelativeOrigin(configuration.getAllowedOriginPattern());
+ CorsHandler corsHandler =
CorsHandler.create().addOriginWithRegex(configuration.getAllowedOriginPattern());
route.handler(corsHandler);
}
diff --git
a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebSocketTestSupport.java
b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebSocketTestSupport.java
index 5778d3acaa2e..e48e9e790c45 100644
---
a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebSocketTestSupport.java
+++
b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebSocketTestSupport.java
@@ -26,8 +26,8 @@ import io.vertx.core.Handler;
import io.vertx.core.Vertx;
import io.vertx.core.VertxException;
import io.vertx.core.VertxOptions;
-import io.vertx.core.http.HttpClient;
import io.vertx.core.http.WebSocket;
+import io.vertx.core.http.WebSocketClient;
import io.vertx.core.impl.VertxInternal;
import io.vertx.core.impl.btc.BlockedThreadEvent;
import io.vertx.ext.web.Route;
@@ -60,8 +60,8 @@ public class VertxWebSocketTestSupport extends
CamelTestSupport {
}
public WebSocket openWebSocketConnection(String host, int port, String
path, Consumer<String> handler) throws Exception {
- HttpClient client = Vertx.vertx().createHttpClient();
- CompletableFuture<WebSocket> future = client.webSocket(port, host,
path)
+ WebSocketClient client = Vertx.vertx().createWebSocketClient();
+ CompletableFuture<WebSocket> future = client.connect(port, host, path)
.toCompletionStage()
.toCompletableFuture();
WebSocket webSocket = future.get(5, TimeUnit.SECONDS);