diff --git 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 index 025b259a..b178d6e8 100644 --- 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? { + // Prevent Rouge trigger when replayed + if (history.any { it is CollectedEvent }) return null val collectProjection = CollectProjection(history) log.info { collectProjection.prettyPrint() }