Disabling re-consumption

2026-01-29 16:57:45 +01:00 · 2026-01-29 16:57:45 +01:00 · 71359254f2
commit 71359254f2
parent 1d43b9b0a0
1 changed files with 2 additions and 0 deletions
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/CollectEventsListener.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/CollectEventsListener.kt
@ -16,6 +16,8 @@ class CollectEventsListener: EventListener() {
        event: Event,
        history: List<Event>
    ): Event? {
+        // Prevent Rouge trigger when replayed
+        if (history.any { it is CollectedEvent }) return null

        val collectProjection = CollectProjection(history)
        log.info { collectProjection.prettyPrint() }