Commit 8bfaf2ec authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Update name of step for updates.

parent d258c2bd
......@@ -218,6 +218,7 @@ class BulkProcessor(
}
private fun executeUpdateRequest(consumerRecord: ConsumerRecord<String, String>): List<Report> {
val serviceNameUpdate = "$serviceName-update"
val updateQuery = try {
mapper.readValue<UpdateQuery>(consumerRecord.value(), UpdateQuery::class.java).let {
it
......@@ -225,7 +226,7 @@ class BulkProcessor(
consumerRecord.key(),
ReportStatus.fatal,
"Input message is empty.",
serviceName
serviceNameUpdate
))
}
} catch (ex: JsonProcessingException) {
......@@ -234,7 +235,7 @@ class BulkProcessor(
consumerRecord.key(),
ReportStatus.fatal,
"JSON Parse Error: ${ex.localizedMessage}",
serviceName
serviceNameUpdate
))
} catch (ex: JsonMappingException) {
log.error("JSON Parse Error: ${ex.localizedMessage}")
......@@ -242,7 +243,7 @@ class BulkProcessor(
consumerRecord.key(),
ReportStatus.fatal,
"JSON Parse Error: ${ex.localizedMessage}",
serviceName
serviceNameUpdate
))
}
......@@ -260,7 +261,7 @@ class BulkProcessor(
consumerRecord.key(),
ReportStatus.fatal,
"Indexing Failure: ${it.message}",
serviceName
serviceNameUpdate
)
}
} else {
......@@ -268,7 +269,7 @@ class BulkProcessor(
consumerRecord.key(),
ReportStatus.success,
"",
serviceName
serviceNameUpdate
))
}
......@@ -278,7 +279,7 @@ class BulkProcessor(
consumerRecord.key(),
ReportStatus.fatal,
"Unknown Exception: ${ex.localizedMessage}",
serviceName
serviceNameUpdate
))
}
}
......
Supports Markdown
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