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

Update

Browse Source
This commit is contained in:
bskjon 2024-04-19 02:43:06 +02:00
parent 84bc18ab41
commit 7638f573dd
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -35,7 +35,7 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
} else {
io.launch {
delay(1000) // Give the database a few sec to update
readAllMessagesFor(event.value.referenceId, event.value.eventId)
readAllMessagesFor(event.value.referenceId, event.value.eventId, event.key.event)
}
}
}
@ -110,10 +110,10 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
}
}
fun readAllMessagesFor(referenceId: String, eventId: String) {
fun readAllMessagesFor(referenceId: String, eventId: String, event: String) {
val messages = eventManager.getEventsWith(referenceId)
if (messages.find { it.eventId == eventId && it.referenceId == referenceId } == null) {
log.warn { "EventId ($eventId) for ReferenceId ($referenceId) has not been made available in the database yet." }
log.warn { "EventId ($eventId) for ReferenceId ($referenceId) with event $event has not been made available in the database yet." }
io.launch {
val fixedDelay = 1000L
delay(fixedDelay)

2
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt
View File

@ -27,7 +27,7 @@ class CreateConvertWorkTask(@Autowired override var coordinator: Coordinator) :
)
override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
log.info { "${event.referenceId} triggered by ${event.event}" }
log.info { "${event.referenceId} @ ${event.eventId} triggered by ${event.event}" }
if (!event.data.isSuccess()) {
return null