diff --git a/Reader/build.gradle.kts b/Reader/build.gradle.kts
index a6bfbe03..e0828256 100644
--- a/Reader/build.gradle.kts
+++ b/Reader/build.gradle.kts
@@ -23,7 +23,7 @@ repositories {
 }
 
 dependencies {
-    implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha47")
+    implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha48")
     implementation("no.iktdev:exfl:0.0.8-SNAPSHOT")
 
 
diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/contentDeterminator/ContentDeterminate.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/contentDeterminator/ContentDeterminate.kt
index f62114ce..9a6ba22c 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/contentDeterminator/ContentDeterminate.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/contentDeterminator/ContentDeterminate.kt
@@ -35,7 +35,7 @@ class ContentDeterminate: DefaultKafkaReader("contentDeterminate"), ISequentialM
 
 
     override fun getRequiredMessages(): List<String> {
-        return listOf(KafkaEvents.EVENT_READER_RECEIVED_FILE.event, KafkaEvents.EVENT_METADATA_OBTAINED.event)
+        return mainListener.subAccepts + listOf(mainListener.accept)
     }
 
     override fun onAllMessagesProcessed(referenceId: String, result: Map<String, Message?>) {
diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
index a04aa238..24f127ce 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
@@ -46,7 +46,7 @@ class EncodedStreams : ISequentialMessageEvent {
 
 
     override fun getRequiredMessages(): List<String> {
-        return listOf(KafkaEvents.EVENT_READER_RECEIVED_FILE.event, KafkaEvents.EVENT_READER_RECEIVED_STREAMS.event)
+        return mainListener.subAccepts + listOf(mainListener.accept)
     }
 
     override fun onAllMessagesProcessed(referenceId: String, result: Map<String, Message?>) {