From 71359254f298e5301633e1bbd59d1bb4e7b9c931 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Brage=20Skj=C3=B8nborg?= <bskjon@outlook.com>
Date: Thu, 29 Jan 2026 16:57:45 +0100
Subject: [PATCH] Disabling re-consumption

---
 .../coordinator/listeners/events/CollectEventsListener.kt       | 2 ++
 1 file changed, 2 insertions(+)

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