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

Adjustments

Browse Source
This commit is contained in:
bskjon 2024-04-13 17:21:44 +02:00
parent 3d64a99213
commit b5a7aa0f36
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterCoordinator.kt
View File

@ -43,7 +43,7 @@ class ConverterCoordinator() : CoordinatorBase<PersistentProcessDataMessage, Per
if (event.key == KafkaEvents.EventWorkConvertCreated) { if (event.key == KafkaEvents.EventWorkConvertCreated) {
val success = eventManager.setProcessEvent(event.key, event.value) val success = eventManager.setProcessEvent(event.key, event.value)
if (!success) { if (!success) {
log.error { "Unable to store message: ${event.key.event} in database ${getEventsDatabase().database}!" } log.error { "Unable to store message event: ${event.key.event} with eventId ${event.value.eventId} with referenceId ${event.value.referenceId} in database ${getEventsDatabase().database}!" }
} else { } else {
readAllMessagesFor(event.value.referenceId, event.value.eventId) readAllMessagesFor(event.value.referenceId, event.value.eventId)
} }

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

@ -28,7 +28,7 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
override fun onMessageReceived(event: DeserializedConsumerRecord<KafkaEvents, Message<out MessageDataWrapper>>) { override fun onMessageReceived(event: DeserializedConsumerRecord<KafkaEvents, Message<out MessageDataWrapper>>) {
val success = eventManager.setEvent(event.key, event.value) val success = eventManager.setEvent(event.key, event.value)
if (!success) { if (!success) {
log.error { "Unable to store message: ${event.key.event} in database ${getEventsDatabase().config.databaseName}" } log.error { "Unable to store message event: ${event.key.event} with eventId ${event.value.eventId} with referenceId ${event.value.referenceId} in database ${getEventsDatabase().database}!" }
} else { } else {
io.launch { io.launch {
delay(1000) // Give the database a few sec to update delay(1000) // Give the database a few sec to update

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

@ -60,7 +60,7 @@ class Coordinator(): CoordinatorBase<PersistentProcessDataMessage, PersistentEve
val success = eventManager.setProcessEvent(event.key, event.value) val success = eventManager.setProcessEvent(event.key, event.value)
if (!success) { if (!success) {
log.error { "Unable to store message: ${event.key.event} in database ${getEventsDatabase().database}" } log.error { "Unable to store message event: ${event.key.event} with eventId ${event.value.eventId} with referenceId ${event.value.referenceId} in database ${getEventsDatabase().database}!" }
} else { } else {
io.launch { io.launch {
delay(500) delay(500)