Commit 93242b5c authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Update report messages.

parent 31357abd
...@@ -83,7 +83,7 @@ class KafkaTopology( ...@@ -83,7 +83,7 @@ class KafkaTopology(
handledStream[0] handledStream[0]
.mapValues { readOnlyKey, value -> .mapValues { readOnlyKey, value ->
Report(readOnlyKey, ReportStatus.fatal, value.third, Service.step).toJson() Report(readOnlyKey, ReportStatus.fatal, "CONFIGURATION ERROR: ${value.third}", Service.step).toJson()
} }
.to(reportTopic) .to(reportTopic)
...@@ -221,7 +221,7 @@ class KafkaTopology( ...@@ -221,7 +221,7 @@ class KafkaTopology(
result.first, result.first,
Pair( Pair(
result.second, result.second,
Report(result.first, ReportStatus.success, "", Service.step) Report(result.first, ReportStatus.success, "Generated RDF document.", Service.step)
) )
) )
} else { } else {
...@@ -260,10 +260,10 @@ class KafkaTopology( ...@@ -260,10 +260,10 @@ class KafkaTopology(
} }
} catch (ex: InvalidMappingException) { } catch (ex: InvalidMappingException) {
log.error(ex.localizedMessage) log.error(ex.localizedMessage)
Triple(null, null, Report(key, ReportStatus.fatal, ex.localizedMessage, Service.step)) Triple(null, null, Report(key, ReportStatus.fatal, "InvalidMappingException: ${ex.localizedMessage}", Service.step))
} catch (ex: KlaxonException) { } catch (ex: KlaxonException) {
log.error(ex.localizedMessage) log.error(ex.localizedMessage)
Triple(null, null, Report(key, ReportStatus.fatal, ex.localizedMessage, Service.step)) Triple(null, null, Report(key, ReportStatus.fatal, "KLAXON EXCEPTION: ${ex.localizedMessage}", Service.step))
} catch (ex: NullPointerException) { } catch (ex: NullPointerException) {
log.error(ex.localizedMessage) log.error(ex.localizedMessage)
Triple( Triple(
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment