This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.14.x by this push:
new 951b79bdd0f3 CAMEL-22785 Start master consumers in an asynchronous
manner (#20455)
951b79bdd0f3 is described below
commit 951b79bdd0f3ea84f62b4a62fc85aa503ce4193b
Author: myroch <[email protected]>
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;
}