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);

Reply via email to