Reason added to headers

Author: RettIProd

ebms-async/src/main/kotlin/no/nav/emottak/ebms/async/App.kt

@@ -244,7 +244,8 @@ fun Route.simulateError(): Route = get("/api/forceretry/{$KAFKA_OFFSET}") {
                 (call.parameters[KAFKA_OFFSET])?.toLong() ?: 0
             )
             failedMessageQueue.sendToRetry(
-                record = record ?: throw Exception("No Record found. Offset: ${call.parameters[KAFKA_OFFSET]}")
+                record = record ?: throw Exception("No Record found. Offset: ${call.parameters[KAFKA_OFFSET]}"),
+                reason = "Simulated Error"
             )
         }
     }

ebms-async/src/main/kotlin/no/nav/emottak/ebms/async/kafka/consumer/FailedMessageKafkaHandler.kt

@@ -33,6 +33,7 @@ import kotlin.time.Duration.Companion.seconds
 val failedMessageQueue: FailedMessageKafkaHandler = FailedMessageKafkaHandler()
 const val RETRY_COUNT_HEADER = "retryCount"
 const val RETRY_AFTER = "retryableAfter"
+const val RETRY_REASON = "retryReason"
 
 val logger = LoggerFactory.getLogger(FailedMessageKafkaHandler::class.java)
 
@@ -65,8 +66,12 @@ class FailedMessageKafkaHandler(
     suspend fun sendToRetry(
         record: ReceiverRecord<String, ByteArray>,
         key: String = record.key(),
-        value: ByteArray = record.value()
+        value: ByteArray = record.value(),
+        reason: String? = null
     ) {
+        if (reason != null) {
+            record.addHeader(RETRY_REASON, reason)
+        }
         record.addHeader(RETRY_AFTER, getNextRetryTime(record))
         try {
             val metadata = publisher.publishScope {

ebms-async/src/main/kotlin/no/nav/emottak/ebms/async/processing/PayloadMessageProcessor.kt

@@ -97,7 +97,12 @@ class PayloadMessageProcessor(
             returnMessageError(ebmsPayloadMessage, e)
         } catch (ex: Exception) {
             log.error(ebmsPayloadMessage.marker(), ex.message ?: "Unknown error", ex)
-            failedMessageQueue.sendToRetry(record, ebmsPayloadMessage.requestId, ebmsPayloadMessage.toEbmsDokument().dokument.asByteArray())
+            failedMessageQueue.sendToRetry(
+                record,
+                ebmsPayloadMessage.requestId,
+                ebmsPayloadMessage.toEbmsDokument().dokument.asByteArray(),
+                ex.message ?: "Unknown error"
+            )
             throw ex
         }
     }