(camel) branch main updated: Avoid deprecated Method for VertXThreadPoolFactory (#19426)

[davsclaus]

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

davsclaus 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 e6bf26b91ee3 Avoid deprecated Method for VertXThreadPoolFactory 
(#19426)
e6bf26b91ee3 is described below

commit e6bf26b91ee379ffbf217e14596b4ffb1f1a886b
Author: Aurélien Pupier <apup...@ibm.com>
AuthorDate: Fri Oct 3 18:23:56 2025 +0200

    Avoid deprecated Method for VertXThreadPoolFactory (#19426)
    
    Signed-off-by: Aurélien Pupier <apup...@ibm.com>
---
 .../org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java     | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-threadpoolfactory-vertx/src/main/java/org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java
 
b/components/camel-threadpoolfactory-vertx/src/main/java/org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java
index 288ea317fca0..f3dc76ca6d2e 100644
--- 
a/components/camel-threadpoolfactory-vertx/src/main/java/org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java
+++ 
b/components/camel-threadpoolfactory-vertx/src/main/java/org/apache/camel/reactive/vertx/VertXThreadPoolFactory.java
@@ -23,6 +23,7 @@ import java.util.concurrent.Callable;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
@@ -166,10 +167,7 @@ public class VertXThreadPoolFactory extends 
DefaultThreadPoolFactory implements
         public void execute(Runnable command) {
             LOG.trace("execute: {}", command);
             // used by vertx
-            vertx.executeBlocking(future -> {
-                command.run();
-                future.complete();
-            }, null);
+            vertx.executeBlocking(Executors.callable(command));
         }
     }