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

Fix attempt 3

Browse Source
This commit is contained in:
Brage 2023-07-23 21:55:03 +02:00
parent dc2c491fff
commit b57ea20e3a
2 changed files with 3 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-alpha67") implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha68")
implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha7") implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha7")

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

@ -31,7 +31,8 @@ class EncodedStreams : DefaultKafkaReader("streamSelector"), ICollectedMessagesE
consumer = defaultConsumer, consumer = defaultConsumer,
initiatorEvent = KafkaEvents.EVENT_READER_RECEIVED_FILE, initiatorEvent = KafkaEvents.EVENT_READER_RECEIVED_FILE,
completionEvent = KafkaEvents.EVENT_READER_DETERMINED_FILENAME, completionEvent = KafkaEvents.EVENT_READER_DETERMINED_FILENAME,
listener = this listener = this,
eventCollectionClass = ResultCollection::class.java
) )
init { init {