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

Logging

Browse Source
This commit is contained in:
Brage 2023-07-18 22:34:35 +02:00
parent 462675a78e
commit 35d0498493
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -31,6 +31,7 @@ class StreamsReader {
object: EventMessageListener(CommonConfig.kafkaTopic, defaultConsumer, listOf(EVENT_READER_RECEIVED_FILE.event)) { object: EventMessageListener(CommonConfig.kafkaTopic, defaultConsumer, listOf(EVENT_READER_RECEIVED_FILE.event)) {
override fun onMessage(data: ConsumerRecord<String, Message>) { override fun onMessage(data: ConsumerRecord<String, Message>) {
logger.info { "RECORD: ${data.key()}" } logger.info { "RECORD: ${data.key()}" }
logger.info { "Active filters: ${this.acceptsEvents.joinToString(",") }}" }
if (data.value().status.statusType != StatusType.SUCCESS) { if (data.value().status.statusType != StatusType.SUCCESS) {
logger.info { "Ignoring event: ${data.key()} as status is not Success!" } logger.info { "Ignoring event: ${data.key()} as status is not Success!" }
return return
@ -38,7 +39,7 @@ class StreamsReader {
val dataValue = data.value().dataAs(FileWatcher.FileResult::class.java) val dataValue = data.value().dataAs(FileWatcher.FileResult::class.java)
if (dataValue == null) { if (dataValue == null) {
logger.info { "Ignoring event: ${data.key()} as values is not of expected type!, ${data.value().data}" } logger.info { "Ignoring event: ${data.key()} as values is not of expected type!" }
return return
} }
logger.info { "Preparing Probe for ${dataValue.file}" } logger.info { "Preparing Probe for ${dataValue.file}" }