fix: not reuse readers

The exporter and the record stream shared the same reader, which caused IndexOutOfBounds exceptions due to concurrent access
camunda-community-hub · Dec 1, 2021 · 949804a · 949804a
1 parent abdd511
commit 949804a
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/eze/src/main/kotlin/org/camunda/community/eze/EngineFactory.kt b/eze/src/main/kotlin/org/camunda/community/eze/EngineFactory.kt
@@ -81,11 +81,12 @@ object EngineFactory {
             grpcResponseWriter
         )
 
-        val reader = logStream.newLogStreamReader().join()
+        val exporterReader = logStream.newLogStreamReader().join()
+        val recordStreamReader = logStream.newLogStreamReader().join()
 
         val exporterRunner = ExporterRunner(
             exporters = exporters,
-            reader = { position -> createRecordStream(reader, position) }
+            reader = { position -> createRecordStream(exporterReader, position) }
         )
         logStream.registerRecordAvailableListener(exporterRunner::onRecordsAvailable)
 
@@ -105,7 +106,7 @@ object EngineFactory {
                 logStream.close()
                 scheduler.stop()
             },
-            recordStream = { createRecordStream(reader) },
+            recordStream = { createRecordStream(recordStreamReader) },
             clock = clock
         )
     }