Skip to content

Commit 2e70d4a

Browse files
authored
CAMEL-22785 Start master consumers in an asynchronous manner (#20455)
1 parent 654d7d7 commit 2e70d4a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ private void onLeadershipTaken() throws Exception {
163163
}
164164

165165
final BackgroundTask leaderTask = createTask();
166-
leaderTask.run(getEndpoint().getCamelContext(), () -> {
166+
leaderTask.schedule(getEndpoint().getCamelContext(), () -> {
167167
if (!isRunAllowed()) {
168168
return false;
169169
}

0 commit comments

Comments
 (0)