diff --git a/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineFactory.java b/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineFactory.java index c5244cdbe..77fd85734 100644 --- a/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineFactory.java +++ b/engine/src/main/java/io/camunda/zeebe/process/test/engine/EngineFactory.java @@ -67,7 +67,7 @@ private static ZeebeTestEngine create(final int port, final Consumer req final ActorScheduler scheduler = createAndStartActorScheduler(clock); final InMemoryLogStorage logStorage = new InMemoryLogStorage(); - final LogStream logStream = createLogStream(logStorage, scheduler, partitionId, clock); + final LogStream logStream = createLogStream(logStorage, partitionId, clock); final CommandWriter commandWriter = new CommandWriter(logStream.newLogStreamWriter()); final CommandSender commandSender = new CommandSender(commandWriter); @@ -124,14 +124,10 @@ private static ActorScheduler createAndStartActorScheduler(final ActorClock cloc } private static LogStream createLogStream( - final LogStorage logStorage, - final ActorSchedulingService scheduler, - final int partitionId, - final ActorClock clock) { + final LogStorage logStorage, final int partitionId, final ActorClock clock) { return LogStream.builder() .withPartitionId(partitionId) .withLogStorage(logStorage) - .withActorSchedulingService(scheduler) .withClock(clock) .build(); }