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

Fixed operations

Browse Source
This commit is contained in:
bskjon 2024-05-06 00:35:07 +02:00
parent e776e00375
commit 92794574d7
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -70,7 +70,8 @@ class Coordinator() : CoordinatorBase<PersistentMessage, PersistentEventBasedMes
val processStartEvent = MediaProcessStarted( val processStartEvent = MediaProcessStarted(
status = Status.COMPLETED, status = Status.COMPLETED,
file = file.absolutePath, file = file.absolutePath,
type = type type = type,
operations = operations
) )
producer.sendMessage(UUID.randomUUID().toString(), KafkaEvents.EventMediaProcessStarted, processStartEvent) producer.sendMessage(UUID.randomUUID().toString(), KafkaEvents.EventMediaProcessStarted, processStartEvent)
return referenceId return referenceId