From e090e98fa52543a6309230b74a941fd1a13cb645 Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Tue, 23 Apr 2024 00:44:05 +0200
Subject: [PATCH] Test

---
 .../no/iktdev/mediaprocessing/processer/Coordinator.kt       | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
index 3498f74c..d622f1d5 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
@@ -89,8 +89,9 @@ class Coordinator(): CoordinatorBase<PersistentProcessDataMessage, PersistentEve
         val messages = eventManager.getProcessEventsClaimable()
         io.launch {
             messages.forEach {
-                delay(1000)
-                createTasksBasedOnEventsAndPersistence(referenceId = it.referenceId, eventId = it.eventId, messages)
+                delay(500)
+                listeners.forwardBatchEventMessagesToListeners(listOf(it))
+                //createTasksBasedOnEventsAndPersistence(referenceId = it.referenceId, eventId = it.eventId, messages)
             }
         }
     }