Merge pull request #10586 from camunda/backport-10468-to-release-8.1.0

[Backport release-8.1.0] Migrate StreamProcessor test
camunda · Sep 30, 2022 · c7ff8cd · c7ff8cd
2 parents dea0635 + 352e767
commit c7ff8cd
Show file tree

Hide file tree

Showing 5 changed files with 742 additions and 737 deletions.
diff --git a/...st/java/io/camunda/zeebe/engine/processing/streamprocessor/StreamProcessorHealthTest.java b/...st/java/io/camunda/zeebe/engine/processing/streamprocessor/StreamProcessorHealthTest.java
@@ -48,7 +48,7 @@ void shouldMarkUnhealthyWhenLoopInErrorHandling() {
     // given
     streamProcessor = streamPlatform.startStreamProcessor();
 
-    final var mockProcessor = streamPlatform.getDefaultRecordProcessor();
+    final var mockProcessor = streamPlatform.getDefaultMockedRecordProcessor();
     when(mockProcessor.process(any(), any())).thenThrow(new RuntimeException("expected"));
     when(mockProcessor.onProcessingError(any(), any(), any()))
         .thenThrow(new RuntimeException("expected"));
@@ -70,7 +70,7 @@ void shouldBecomeHealthyWhenErrorIsResolved() {
     streamProcessor = streamPlatform.startStreamProcessor();
     final var shouldFail = new AtomicBoolean(true);
 
-    final var mockProcessor = streamPlatform.getDefaultRecordProcessor();
+    final var mockProcessor = streamPlatform.getDefaultMockedRecordProcessor();
     when(mockProcessor.process(any(), any())).thenThrow(new RuntimeException("expected"));
     when(mockProcessor.onProcessingError(any(), any(), any()))
         .thenAnswer(