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

OVerride test

Browse Source
This commit is contained in:
Brage 2023-07-19 03:12:09 +02:00
parent f245f14291
commit 63423666c7
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt
View File

@ -71,6 +71,21 @@ class StreamsReader {
val message = Message(status = Status( statusType = if (resultCode == 0) StatusType.SUCCESS else StatusType.ERROR), data = output.joinToString("\n")) val message = Message(status = Status( statusType = if (resultCode == 0) StatusType.SUCCESS else StatusType.ERROR), data = output.joinToString("\n"))
messageProducer.sendMessage(KnownEvents.EVENT_READER_RECEIVED_STREAMS.event, message) messageProducer.sendMessage(KnownEvents.EVENT_READER_RECEIVED_STREAMS.event, message)
} }
override fun filter(consumerRecord: ConsumerRecord<String, Message>): Boolean {
return shouldIgnoreMessageO(consumerRecord)
}
fun shouldIgnoreMessageO(consumerRecord: ConsumerRecord<String, Message>): Boolean {
logger.info { "Consumer filter validating against ${consumerRecord.key()}" }
if (consumerRecord.key().isNullOrBlank()) {
logger.info { "Consumer event is null or blank, ignoring!" }
return true
}
val isEventAccepted = accepts.any { it == consumerRecord.key() }
logger.info { "Consumer event is ${if (isEventAccepted) "found" else "not found"} within accepts" }
return !isEventAccepted
}
}.listen() }.listen()
} }