merge: #10050

10050: Engine abstraction remove obsolete code r=pihme a=pihme ## Description Removes code that is no longer needed. Started out with a class, and then I found more. ## Related issues related to #9727 Co-authored-by: pihme <pihme@users.noreply.github.com>
camunda · Aug 10, 2022 · 3487dab · 3487dab
2 parents 77f9f1d + b85075c
commit 3487dab
Show file tree

Hide file tree

Showing 5 changed files with 1 addition and 152 deletions.
diff --git a/engine/src/main/java/io/camunda/zeebe/engine/Loggers.java b/engine/src/main/java/io/camunda/zeebe/engine/Loggers.java
@@ -13,8 +13,6 @@
 public final class Loggers {
   public static final Logger STREAM_PROCESSING =
       LoggerFactory.getLogger("io.camunda.zeebe.broker.logstreams");
-  public static final Logger PROCESS_REPOSITORY_LOGGER =
-      LoggerFactory.getLogger("io.camunda.zeebe.broker.process.repository");
 
   public static final Logger PROCESS_PROCESSOR_LOGGER =
       LoggerFactory.getLogger("io.camunda.zeebe.broker.process");

diff --git a/...n/java/io/camunda/zeebe/engine/processing/bpmn/behavior/LegacyTypedStreamWriterProxy.java b/...n/java/io/camunda/zeebe/engine/processing/bpmn/behavior/LegacyTypedStreamWriterProxy.java
diff --git a/...n/java/io/camunda/zeebe/engine/processing/streamprocessor/writers/ReprocessingRecord.java b/...n/java/io/camunda/zeebe/engine/processing/streamprocessor/writers/ReprocessingRecord.java
diff --git a/engine/src/main/java/io/camunda/zeebe/streamprocessor/StreamProcessor.java b/engine/src/main/java/io/camunda/zeebe/streamprocessor/StreamProcessor.java
@@ -340,7 +340,7 @@ private long recoverFromSnapshot() {
 
     streamProcessorDbState = new StreamProcessorDbState(zeebeDb, transactionContext);
     streamProcessorContext.lastProcessedPositionState(
-        getStreamProcessorDbState().getLastProcessedPositionState());
+        streamProcessorDbState.getLastProcessedPositionState());
 
     final long snapshotPosition =
         streamProcessorDbState
@@ -366,7 +366,6 @@ private long recoverFromSnapshot() {
   private void recoverZeebeDbState(final TransactionContext transactionContext) {
     final ZeebeDbState zeebeState = new ZeebeDbState(partitionId, zeebeDb, transactionContext);
     streamProcessorContext.zeebeState(zeebeState);
-    streamProcessorContext.eventApplier(eventApplierFactory.apply(zeebeState));
   }
 
   private void onRecovered(final LastProcessingPositions lastProcessingPositions) {

diff --git a/engine/src/main/java/io/camunda/zeebe/streamprocessor/StreamProcessorContext.java b/engine/src/main/java/io/camunda/zeebe/streamprocessor/StreamProcessorContext.java
@@ -14,7 +14,6 @@
 import io.camunda.zeebe.engine.processing.streamprocessor.StreamProcessorListener;
 import io.camunda.zeebe.engine.processing.streamprocessor.writers.CommandResponseWriter;
 import io.camunda.zeebe.engine.processing.streamprocessor.writers.LegacyTypedStreamWriter;
-import io.camunda.zeebe.engine.state.EventApplier;
 import io.camunda.zeebe.engine.state.KeyGeneratorControls;
 import io.camunda.zeebe.engine.state.ZeebeDbState;
 import io.camunda.zeebe.engine.state.mutable.MutableZeebeState;
@@ -38,7 +37,6 @@ public final class StreamProcessorContext implements ReadonlyStreamProcessorCont
   private RecordValues recordValues;
   private ZeebeDbState zeebeState;
   private TransactionContext transactionContext;
-  private EventApplier eventApplier;
 
   private BooleanSupplier abortCondition;
   private StreamProcessorListener streamProcessorListener = NOOP_LISTENER;
@@ -143,11 +141,6 @@ public DirectTypedResponseWriterImpl getTypedResponseWriter() {
     return typedResponseWriter;
   }
 
-  public StreamProcessorContext eventApplier(final EventApplier eventApplier) {
-    this.eventApplier = eventApplier;
-    return this;
-  }
-
   public StreamProcessorContext processorMode(final StreamProcessorMode streamProcessorMode) {
     this.streamProcessorMode = streamProcessorMode;
     return this;