iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Catches

Browse Source
This commit is contained in:
Brage 2024-03-15 01:34:54 +01:00
parent e159560bca
commit 6c9d1da854
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/Coordinator.kt
View File

@ -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)