refactor: remove LogStream from API

Finally remove the LogStream from the API, which removed the last remaining LogStream knowledge from the engine/processing API
camunda · Sep 30, 2022 · 332a405 · 332a405
1 parent 7017918
commit 332a405
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 13 deletions.
diff --git a/engine/src/main/java/io/camunda/zeebe/engine/api/ReadonlyStreamProcessorContext.java b/engine/src/main/java/io/camunda/zeebe/engine/api/ReadonlyStreamProcessorContext.java
@@ -7,18 +7,10 @@
  */
 package io.camunda.zeebe.engine.api;
 
-import io.camunda.zeebe.logstreams.log.LogStream;
-
 public interface ReadonlyStreamProcessorContext {
 
   ProcessingScheduleService getScheduleService();
 
-  /**
-   * @return the logstream, on which the processor runs
-   */
-  @Deprecated // only used in EngineRule; TODO remove this
-  LogStream getLogStream();
-
   /**
    * Returns the partition ID
    *

diff --git a/engine/src/main/java/io/camunda/zeebe/streamprocessor/StreamProcessorContext.java b/engine/src/main/java/io/camunda/zeebe/streamprocessor/StreamProcessorContext.java
@@ -71,16 +71,15 @@ public ProcessingScheduleService getScheduleService() {
     return processingScheduleService;
   }
 
-  @Override
-  public LogStream getLogStream() {
-    return logStream;
-  }
-
   @Override
   public int getPartitionId() {
     return getLogStream().getPartitionId();
   }
 
+  public LogStream getLogStream() {
+    return logStream;
+  }
+
   public MutableLastProcessedPositionState getLastProcessedPositionState() {
     return lastProcessedPositionState;
   }