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

Test

Browse Source
This commit is contained in:
bskjon 2024-04-23 00:44:05 +02:00
parent 5c1a8bd105
commit e090e98fa5
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
View File

@ -89,8 +89,9 @@ class Coordinator(): CoordinatorBase<PersistentProcessDataMessage, PersistentEve
val messages = eventManager.getProcessEventsClaimable() val messages = eventManager.getProcessEventsClaimable()
io.launch { io.launch {
messages.forEach { messages.forEach {
delay(1000) delay(500)
createTasksBasedOnEventsAndPersistence(referenceId = it.referenceId, eventId = it.eventId, messages) listeners.forwardBatchEventMessagesToListeners(listOf(it))
//createTasksBasedOnEventsAndPersistence(referenceId = it.referenceId, eventId = it.eventId, messages)
} }
} }
} }