diff --git a/engine/src/main/java/io/camunda/zeebe/streamprocessor/ProcessingScheduleServiceImpl.java b/engine/src/main/java/io/camunda/zeebe/streamprocessor/ProcessingScheduleServiceImpl.java index 06c551737847..31f9a17263bf 100644 --- a/engine/src/main/java/io/camunda/zeebe/streamprocessor/ProcessingScheduleServiceImpl.java +++ b/engine/src/main/java/io/camunda/zeebe/streamprocessor/ProcessingScheduleServiceImpl.java @@ -81,7 +81,7 @@ private void useActorControl(final Runnable task) { LOG.debug("ProcessingScheduleService hasn't been opened yet, ignore scheduled task."); return; } - actorControl.submit(task); + task.run(); } public ActorFuture open(final ActorControl control) {