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

Creating a cache of "consumed" eventIds

Browse Source
This commit is contained in:
bskjon 2024-04-22 01:01:00 +02:00
parent d6a8ea6297
commit ea992e6ea7
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt
View File

@ -39,4 +39,9 @@ abstract class TaskCreator(coordinator: ConverterCoordinator) :
override fun prerequisiteRequired(event: PersistentProcessDataMessage): List<() -> Boolean> { override fun prerequisiteRequired(event: PersistentProcessDataMessage): List<() -> Boolean> {
return listOf() return listOf()
} }
override fun containsUnprocessedEvents(events: List<PersistentProcessDataMessage>): Boolean {
return true
}
} }

4
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt
View File

@ -37,4 +37,8 @@ abstract class TaskCreator(coordinator: Coordinator) :
override fun prerequisiteRequired(event: PersistentProcessDataMessage): List<() -> Boolean> { override fun prerequisiteRequired(event: PersistentProcessDataMessage): List<() -> Boolean> {
return listOf() return listOf()
} }
override fun containsUnprocessedEvents(events: List<PersistentProcessDataMessage>): Boolean {
return true
}
} }