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 b178d6e8..df395d11 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 @@ -17,7 +17,7 @@ class CollectEventsListener: EventListener() { history: List ): Event? { // Prevent Rouge trigger when replayed - if (history.any { it is CollectedEvent }) return null + if (event is CollectedEvent || history.any { it is CollectedEvent }) return null val collectProjection = CollectProjection(history) log.info { collectProjection.prettyPrint() }