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

Changed to listens for

Browse Source
This commit is contained in:
bskjon 2024-05-06 00:53:26 +02:00
parent 92794574d7
commit b0f6e354ea
1 changed files with 1 additions and 5 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/tasks/event/CreateConvertWorkTask.kt
View File

@ -24,12 +24,8 @@ class CreateConvertWorkTask(@Autowired override var coordinator: Coordinator) :
override val producesEvent: KafkaEvents override val producesEvent: KafkaEvents
get() = KafkaEvents.EventWorkConvertCreated get() = KafkaEvents.EventWorkConvertCreated
override val requiredEvents: List<KafkaEvents>
get() = listOf(
KafkaEvents.EventWorkExtractCreated
)
override val listensForEvents: List<KafkaEvents> override val listensForEvents: List<KafkaEvents>
get() = listOf(KafkaEvents.EventMediaProcessStarted) get() = listOf(KafkaEvents.EventMediaProcessStarted, KafkaEvents.EventWorkExtractCreated)
override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? { override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
super.onProcessEventsAccepted(event, events) super.onProcessEventsAccepted(event, events)