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

Changed behaviour

Browse Source
This commit is contained in:
bskjon 2024-04-21 22:17:26 +02:00
parent 88c9d3c306
commit 2f3fff1e64
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -145,7 +145,7 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
@Scheduled(fixedDelay = (5*6_0000)) @Scheduled(fixedDelay = (5*6_0000))
fun checkForWork() { fun checkForWork() {
if (isReady()) { if (isReady()) {
log.info { "Checking if there is any uncompleted event sets" } log.info { "\n\nChecking if there is any uncompleted event sets\n\n" }
readAllUncompletedMessagesInQueue() readAllUncompletedMessagesInQueue()
} }
} }

2
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/PersistentEventManager.kt
View File

@ -184,7 +184,7 @@ class PersistentEventManager(private val dataSource: DataSource) {
if (derivedId != null) { if (derivedId != null) {
val isNewEventOrphan = existing.none { it.eventId == derivedId } val isNewEventOrphan = existing.none { it.eventId == derivedId }
if (isNewEventOrphan) { if (isNewEventOrphan) {
log.warn { "Message not saved! ${message.referenceId} with eventId(${message.eventId}) has derivedEventId($derivedId) which does not exist!" } log.warn { "Message not saved! ${message.referenceId} with eventId(${message.eventId}) for event ${event.event} has derivedEventId($derivedId) which does not exist!" }
return false return false
} }
} }