(camel) branch main updated: CAMEL-22785 Start master consumers in an asynchronous manner (#20455)

[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 2e70d4ab2971 CAMEL-22785 Start master consumers in an asynchronous 
manner (#20455)
2e70d4ab2971 is described below

commit 2e70d4ab297141ef46768c6459526a95f06939e9
Author: myroch <myr...@gmail.com>
AuthorDate: Tue Dec 16 11:01:29 2025 +0100

    CAMEL-22785 Start master consumers in an asynchronous manner (#20455)
---
 .../src/main/java/org/apache/camel/component/master/MasterConsumer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java
 
b/components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java
index a6abaab761c6..06b94fdce31b 100644
--- 
a/components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java
+++ 
b/components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java
@@ -163,7 +163,7 @@ public class MasterConsumer extends DefaultConsumer 
implements ResumeAware<Resum
             }
 
             final BackgroundTask leaderTask = createTask();
-            leaderTask.run(getEndpoint().getCamelContext(), () -> {
+            leaderTask.schedule(getEndpoint().getCamelContext(), () -> {
                 if (!isRunAllowed()) {
                     return false;
                 }