From c9586f0f307c57748bdbe79097a47adeaf54008b Mon Sep 17 00:00:00 2001 From: Jakob Havstein Eriksen Date: Wed, 26 Oct 2022 17:35:03 +0200 Subject: [PATCH] =?UTF-8?q?Rivere=20kan=20putte=20data=20i=20MDC=20f=C3=B8?= =?UTF-8?q?r=20onPacket=20kalles?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Hvorfor: Så man slipper å wrappe innmaten i riverne sine i en lambda. Ulempe: Muligens dumt med litt magi under panseret? --- src/main/kotlin/no/nav/helse/rapids_rivers/River.kt | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/main/kotlin/no/nav/helse/rapids_rivers/River.kt b/src/main/kotlin/no/nav/helse/rapids_rivers/River.kt index 580847a..9e0cce0 100644 --- a/src/main/kotlin/no/nav/helse/rapids_rivers/River.kt +++ b/src/main/kotlin/no/nav/helse/rapids_rivers/River.kt @@ -62,7 +62,9 @@ class River(rapidsConnection: RapidsConnection, private val randomIdGenerator: R it.name(), eventName ).time { - it.onPacket(packet, context) + withMDC(it.dataForMDC(packet)) { + it.onPacket(packet, context) + } } Metrics.onMessageCounter.labels(context.rapidName(), it.name(), "ok").inc() } @@ -101,6 +103,7 @@ class River(rapidsConnection: RapidsConnection, private val randomIdGenerator: R override fun onError(problems: MessageProblems, context: MessageContext) {} fun onSevere(error: MessageProblems.MessageException, context: MessageContext) {} + fun dataForMDC(packet: JsonMessage): Map = emptyMap() fun name(): String = Name(this) }