From e9f972f8b65e28d9ace6a8cca883778ce9788178 Mon Sep 17 00:00:00 2001 From: Brage Date: Tue, 25 Jul 2023 23:45:17 +0200 Subject: [PATCH] Fix --- .../no/iktdev/streamit/content/common/DefaultKafkaReader.kt | 4 ++-- Encode/build.gradle.kts | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/CommonCode/src/main/java/no/iktdev/streamit/content/common/DefaultKafkaReader.kt b/CommonCode/src/main/java/no/iktdev/streamit/content/common/DefaultKafkaReader.kt index e4d41c4b..76e88548 100644 --- a/CommonCode/src/main/java/no/iktdev/streamit/content/common/DefaultKafkaReader.kt +++ b/CommonCode/src/main/java/no/iktdev/streamit/content/common/DefaultKafkaReader.kt @@ -33,10 +33,10 @@ abstract class DefaultKafkaReader(val subId: String) { 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( referenceId = baseMessage.referenceId, - Status(statusType = if (data != null) StatusType.SUCCESS else StatusType.IGNORED), + Status(statusType = status), data = data ) messageProducer.sendMessage(event.event, message) diff --git a/Encode/build.gradle.kts b/Encode/build.gradle.kts index b0597b7f..8e533be1 100644 --- a/Encode/build.gradle.kts +++ b/Encode/build.gradle.kts @@ -23,7 +23,7 @@ repositories { dependencies { 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("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1")