Merge pull request #1241 from camunda/korthout-compile-snapshot

Remove all references of actor scheduler from logstream
camunda · Oct 3, 2024 · fada949 · fada949
2 parents 22bef5d + 7048b77
commit fada949
Showing 1 changed file with 2 additions and 6 deletions.
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
@@ -67,7 +67,7 @@ private static ZeebeTestEngine create(final int port, final Consumer<Intent> 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();
   }