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

Fix

Browse Source
This commit is contained in:
Brage 2023-07-25 23:45:17 +02:00
parent add3d37ff3
commit e9f972f8b6
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
CommonCode/src/main/java/no/iktdev/streamit/content/common/DefaultKafkaReader.kt
View File

@ -33,10 +33,10 @@ abstract class DefaultKafkaReader(val subId: String) {
messageProducer.sendMessage(event.event, message) messageProducer.sendMessage(event.event, message)
} }
fun produceMessage(event: KafkaEvents, baseMessage: Message, data: Any?) { fun produceMessage(event: KafkaEvents, baseMessage: Message, status: StatusType = StatusType.SUCCESS, data: Any?) {
val message = Message( val message = Message(
referenceId = baseMessage.referenceId, referenceId = baseMessage.referenceId,
Status(statusType = if (data != null) StatusType.SUCCESS else StatusType.IGNORED), Status(statusType = status),
data = data data = data
) )
messageProducer.sendMessage(event.event, message) messageProducer.sendMessage(event.event, message)

2
Encode/build.gradle.kts
View File

@ -23,7 +23,7 @@ repositories {
dependencies { dependencies {
implementation(project(":CommonCode")) implementation(project(":CommonCode"))
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha72") implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha75")
implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1") implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1")