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 a6abaab761c65..06b94fdce31be 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 @@ private void onLeadershipTaken() throws Exception {
             }
 
             final BackgroundTask leaderTask = createTask();
-            leaderTask.run(getEndpoint().getCamelContext(), () -> {
+            leaderTask.schedule(getEndpoint().getCamelContext(), () -> {
                 if (!isRunAllowed()) {
                     return false;
                 }