From 6c9d1da85413c2b1e88f19cd1ddcc18aad315110 Mon Sep 17 00:00:00 2001
From: Brage <brage.skjonborg@hotmail.no>
Date: Fri, 15 Mar 2024 01:34:54 +0100
Subject: [PATCH] Catches

---
 .../mediaprocessing/coordinator/Coordinator.kt       | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
index 02bbb7ce..d63ac995 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
@@ -88,7 +88,11 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
         io.launch {
             messages.forEach {
                 delay(1000)
-                listeners.forwardBatchEventMessagesToListeners(it)
+                try {
+                    listeners.forwardBatchEventMessagesToListeners(it)
+                } catch (e: Exception) {
+                    e.printStackTrace()
+                }
                 if (forwarder.hasAnyRequiredEventToCreateProcesserEvents(it)) {
                     if (getProcessStarted(it)?.type == ProcessType.FLOW) {
                         forwarder.produceAllMissingProcesserEvents(
@@ -122,7 +126,11 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
     }
 
     fun operationToRunOnMessages(referenceId: String, eventId: String, messages: List<PersistentMessage>) {
-        createTasksBasedOnEventsAndPersistence(referenceId, eventId, messages)
+        try {
+            createTasksBasedOnEventsAndPersistence(referenceId, eventId, messages)
+        } catch (e: Exception) {
+            e.printStackTrace()
+        }
 
         io.launch {
             buildModelBasedOnMessagesFor(referenceId, messages)