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

Updated lib

Browse Source
This commit is contained in:
Brage 2023-07-19 22:08:20 +02:00
parent 741f7f1391
commit 85fc2756b9
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Reader/build.gradle.kts
View File

@ -23,7 +23,7 @@ repositories {
} }
dependencies { dependencies {
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha42") implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha43")
implementation("no.iktdev:exfl:0.0.6-SNAPSHOT") implementation("no.iktdev:exfl:0.0.6-SNAPSHOT")

2
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt
View File

@ -78,7 +78,7 @@ class EncodedStreams : ISequentialMessageEvent {
logger.info { "All messages are received" } logger.info { "All messages are received" }
val baseMessage = result[KnownEvents.EVENT_READER_RECEIVED_FILE.event] val baseMessage = result[KnownEvents.EVENT_READER_RECEIVED_FILE.event]
if (baseMessage == null) { if (baseMessage == null) {
produceErrorMessage(Message(referenceId = referenceId, status = Status(statusType = StatusType.ERROR)), "No base message found!") produceErrorMessage(Message(referenceId = referenceId, status = Status(statusType = StatusType.ERROR)), "Initiator message not found!")
return return
} }