(camel-quarkus) branch main updated: Replace deprecated Vertx Pump class

[apupier]

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-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new f4b48461d6 Replace deprecated Vertx Pump class
f4b48461d6 is described below

commit f4b48461d650e589450b4c46eea4a9210cd310a1
Author: Aurélien Pupier <apup...@ibm.com>
AuthorDate: Thu Oct 23 10:04:24 2025 +0200

    Replace deprecated Vertx Pump class
    
    Signed-off-by: Aurélien Pupier <apup...@ibm.com>
---
 .../apache/camel/quarkus/component/http/common/HttpTestResource.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/integration-tests-support/http/src/test/java/org/apache/camel/quarkus/component/http/common/HttpTestResource.java
 
b/integration-tests-support/http/src/test/java/org/apache/camel/quarkus/component/http/common/HttpTestResource.java
index 83d36b63a1..58d389169d 100644
--- 
a/integration-tests-support/http/src/test/java/org/apache/camel/quarkus/component/http/common/HttpTestResource.java
+++ 
b/integration-tests-support/http/src/test/java/org/apache/camel/quarkus/component/http/common/HttpTestResource.java
@@ -32,7 +32,6 @@ import io.vertx.core.http.HttpServerRequest;
 import io.vertx.core.http.HttpServerResponse;
 import io.vertx.core.net.NetClient;
 import io.vertx.core.net.NetSocket;
-import io.vertx.core.streams.Pump;
 import org.apache.camel.quarkus.test.AvailablePortFinder;
 import org.jboss.logging.Logger;
 
@@ -142,8 +141,8 @@ public class HttpTestResource implements 
QuarkusTestResourceLifecycleManager {
                             NetSocket serverSocket = 
httpServerRequest.toNetSocket().result();
                             serverSocket.closeHandler(v -> 
clientSocket.close());
                             clientSocket.closeHandler(v -> 
serverSocket.close());
-                            Pump.pump(serverSocket, clientSocket).start();
-                            Pump.pump(clientSocket, serverSocket).start();
+                            serverSocket.pipeTo(clientSocket);
+                            clientSocket.pipeTo(serverSocket);
                         } else {
                             response.setStatusCode(403).end();
                         }