bumper r&r og tbd-libs

navikt · Nov 12, 2024 · e6687f4 · e6687f4
1 parent c851610
commit e6687f4
Show file tree

Hide file tree

Showing 26 changed files with 80 additions and 34 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -1,7 +1,7 @@
 val junitJupiterVersion = "5.11.3"
 val postgresqlVersion = "42.7.2"
-val tbdLibsVersion = "2024.11.07-09.04-76a1afb0"
-val rapidsAndRiversVersion = "2024110709231730967802.bf0cda480345"
+val tbdLibsVersion = "2024.11.12-11.09-16cf2599"
+val rapidsAndRiversVersion = "2024111211071731406062.648687519469"
 val mockkVersion = "1.13.13"
 
 plugins {

diff --git a/src/main/kotlin/no/nav/helse/AktivitetRiver.kt b/src/main/kotlin/no/nav/helse/AktivitetRiver.kt
@@ -5,7 +5,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import org.intellij.lang.annotations.Language
@@ -35,7 +37,7 @@ class AktivitetRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         try {
             //log.info("Inserter aktiviteter for vedtaksperiodeId: ${json["vedtaksperiodeId"].asText()}")
             packet["aktiviteter"]

diff --git a/src/main/kotlin/no/nav/helse/AnnulleringRiver.kt b/src/main/kotlin/no/nav/helse/AnnulleringRiver.kt
@@ -3,7 +3,9 @@ package no.nav.helse
 import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import no.nav.helse.Annullering.Companion.insertAnnullering
 import no.nav.helse.Annullering.Companion.parseAnnullering
 import no.nav.helse.Util.asUuid
@@ -27,7 +29,7 @@ class AnnulleringRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
 
         val jsonNode = packet.jsonNode()
         val annullering = jsonNode.parseAnnullering()

diff --git a/src/main/kotlin/no/nav/helse/FunksjonellFeilOgVarselRiver.kt b/src/main/kotlin/no/nav/helse/FunksjonellFeilOgVarselRiver.kt
@@ -5,7 +5,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import net.logstash.logback.argument.StructuredArguments.keyValue
@@ -33,7 +35,7 @@ class FunksjonellFeilOgVarselRiver(
             }
         }.register(this)
     }
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         sikkerlogg.info("Leser inn {}", keyValue("hendelse", packet.toJson()))
         val opprettet = packet["@opprettet"].asLocalDateTime()
         packet["aktiviteter"]

diff --git a/src/main/kotlin/no/nav/helse/GodkjenningLøsningRiver.kt b/src/main/kotlin/no/nav/helse/GodkjenningLøsningRiver.kt
@@ -4,14 +4,15 @@ import com.fasterxml.jackson.databind.JsonNode
 import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
-import com.github.navikt.tbd_libs.rapids_and_rivers.be
 import com.github.navikt.tbd_libs.rapids_and_rivers.isMissingOrNull
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
 import com.github.navikt.tbd_libs.result_object.getOrThrow
 import com.github.navikt.tbd_libs.retry.retryBlocking
 import com.github.navikt.tbd_libs.speed.SpeedClient
 import io.micrometer.core.instrument.Counter
+import io.micrometer.core.instrument.MeterRegistry
 import net.logstash.logback.argument.StructuredArguments.kv
 import java.util.*
 import javax.sql.DataSource
@@ -48,7 +49,7 @@ class GodkjenningLøsningRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         if (godkjenningAlleredeLagret(packet)) return
 
         val ident = packet["fødselsnummer"].asText()

diff --git a/src/main/kotlin/no/nav/helse/HendelseIkkeHåndtertRiver.kt b/src/main/kotlin/no/nav/helse/HendelseIkkeHåndtertRiver.kt
@@ -6,7 +6,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers.isMissingOrNull
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.Session
 import kotliquery.queryOf
 import no.nav.helse.Util.withSession
@@ -29,7 +31,7 @@ class HendelseIkkeHåndtertRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val hendelseId = UUID.fromString(packet["hendelseId"].asText())
         val opprettet = packet["@opprettet"].asLocalDateTime()
         val årsaker = packet["årsaker"].takeUnless(JsonNode::isMissingOrNull)

diff --git a/src/main/kotlin/no/nav/helse/OppgaveEndretRiver.kt b/src/main/kotlin/no/nav/helse/OppgaveEndretRiver.kt
@@ -5,7 +5,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers.isMissingOrNull
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.TransactionalSession
 import kotliquery.queryOf
 import kotliquery.sessionOf
@@ -31,7 +33,7 @@ class OppgaveEndretRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val oppgaveEndret = OppgaveEndret(
             id = packet["oppgaveId"].asLong(),
             fødselsnummer = packet["fødselsnummer"].asText(),

diff --git a/src/main/kotlin/no/nav/helse/PersonAvstemtRiver.kt b/src/main/kotlin/no/nav/helse/PersonAvstemtRiver.kt
@@ -5,10 +5,12 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDate
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
 import com.github.navikt.tbd_libs.result_object.getOrThrow
 import com.github.navikt.tbd_libs.retry.retryBlocking
 import com.github.navikt.tbd_libs.speed.SpeedClient
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import no.nav.helse.Util.asUuid
@@ -39,7 +41,7 @@ class VedtaksperiodeAvstemt(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val ident = packet["fødselsnummer"].asText()
         val callId = packet["@id"].asText()
         val identer = retryBlocking { speedClient.hentFødselsnummerOgAktørId(ident, callId).getOrThrow() }

diff --git a/src/main/kotlin/no/nav/helse/RevurderingFerdigstiltRiver.kt b/src/main/kotlin/no/nav/helse/RevurderingFerdigstiltRiver.kt
@@ -5,7 +5,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import org.intellij.lang.annotations.Language
@@ -31,7 +33,7 @@ class RevurderingFerdigstiltRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val revurderingId = UUID.fromString(packet["revurderingId"].asText())
         val status = packet["status"].asText()
         val opprettet = packet["@opprettet"].asLocalDateTime()

diff --git a/src/main/kotlin/no/nav/helse/RevurderingIgangsattRiver.kt b/src/main/kotlin/no/nav/helse/RevurderingIgangsattRiver.kt
@@ -6,7 +6,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDate
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import org.intellij.lang.annotations.Language
@@ -40,7 +42,7 @@ class RevurderingIgangsattRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val revurderingId = packet["revurderingId"].let { UUID.fromString(it.asText()) }
         val årsak = packet["årsak"].asText()
         val opprettet = packet["@opprettet"].asLocalDateTime()

diff --git a/src/main/kotlin/no/nav/helse/SendtSøknadRiver.kt b/src/main/kotlin/no/nav/helse/SendtSøknadRiver.kt
@@ -3,7 +3,9 @@ package no.nav.helse
 import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import no.nav.helse.Util.asUuid
@@ -31,7 +33,7 @@ class SendtSøknadRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val dokumentId = packet["id"].asUuid()
         val hendelseId = packet["@id"].asUuid()
         val eventName = packet["@event_name"].asText()

diff --git a/src/main/kotlin/no/nav/helse/SkatteinntekterLagtTilGrunnRiver.kt b/src/main/kotlin/no/nav/helse/SkatteinntekterLagtTilGrunnRiver.kt
@@ -3,8 +3,10 @@ package no.nav.helse
 import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageProblems
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import org.postgresql.util.PSQLException
@@ -24,7 +26,7 @@ class SkatteinntekterLagtTilGrunnRiver(rapidsConnection: RapidsConnection, priva
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         sikkerlogg.info("Leste melding: ${packet.toJson()}")
         val vedtaksperiodeId = packet["vedtaksperiodeId"].asText().let { UUID.fromString(it) }
         val behandlingId = packet["behandlingId"].asText().let { UUID.fromString(it) }
@@ -53,7 +55,7 @@ class SkatteinntekterLagtTilGrunnRiver(rapidsConnection: RapidsConnection, priva
         }
     }
 
-    override fun onError(problems: MessageProblems, context: MessageContext) {
+    override fun onError(problems: MessageProblems, context: MessageContext, metadata: MessageMetadata) {
         sikkerlogg.error(problems.toExtendedReport())
     }
 }
diff --git a/src/main/kotlin/no/nav/helse/SøknadHåndtertRiver.kt b/src/main/kotlin/no/nav/helse/SøknadHåndtertRiver.kt
@@ -4,7 +4,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import org.intellij.lang.annotations.Language
@@ -26,7 +28,7 @@ class SøknadHåndtertRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val søknadHendelseId = UUID.fromString(packet["søknadId"].asText())
         val vedtaksperiodeId = UUID.fromString(packet["vedtaksperiodeId"].asText())
         val opprettet = packet["@opprettet"].asLocalDateTime()

diff --git a/src/main/kotlin/no/nav/helse/TidFraGodkjenningTilUtbetalingRiver.kt b/src/main/kotlin/no/nav/helse/TidFraGodkjenningTilUtbetalingRiver.kt
@@ -5,11 +5,12 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import io.micrometer.core.instrument.Timer
 import kotliquery.queryOf
 import kotliquery.sessionOf
-import kotliquery.using
 import java.time.LocalDateTime
 import java.time.format.DateTimeFormatter
 import java.time.format.DateTimeParseException
@@ -39,7 +40,7 @@ class TidFraGodkjenningTilUtbetalingRiver(
 
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val json = objectMapper.readTree(packet.toJson())
         val vedtaksperiodeId = UUID.fromString(json["vedtaksperiodeId"].asText())
 

diff --git a/src/main/kotlin/no/nav/helse/TilstandendringRiver.kt b/src/main/kotlin/no/nav/helse/TilstandendringRiver.kt
@@ -5,7 +5,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import org.intellij.lang.annotations.Language
@@ -34,7 +36,7 @@ class TilstandendringRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val vedtaksperiodeId = UUID.fromString(packet["vedtaksperiodeId"].asText())
         insertTilstandsendring(
             id = UUID.fromString(packet["@id"].asText()),

diff --git a/src/main/kotlin/no/nav/helse/UtkastTilVedtakRiver.kt b/src/main/kotlin/no/nav/helse/UtkastTilVedtakRiver.kt
@@ -4,8 +4,10 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageProblems
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.queryOf
 import kotliquery.sessionOf
 import org.intellij.lang.annotations.Language
@@ -28,7 +30,7 @@ class UtkastTilVedtakRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val vedtaksperiodeId = UUID.fromString(packet["vedtaksperiodeId"].asText())
         val behandlingId = UUID.fromString(packet["behandlingId"].asText())
         val opprettet = packet["@opprettet"].asLocalDateTime()
@@ -38,7 +40,7 @@ class UtkastTilVedtakRiver(
         logg.info("Lagret utkast_til_vedtak for vedtaksperiodeId=$vedtaksperiodeId")
     }
 
-    override fun onError(problems: MessageProblems, context: MessageContext) {
+    override fun onError(problems: MessageProblems, context: MessageContext, metadata: MessageMetadata) {
         sikkerlogg.error("Klarte ikke å lese utkast_til_vedtak event! ${problems.toExtendedReport()}")
     }
 

diff --git a/src/main/kotlin/no/nav/helse/VarselEndretRiver.kt b/src/main/kotlin/no/nav/helse/VarselEndretRiver.kt
@@ -4,7 +4,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.Session
 import kotliquery.queryOf
 import kotliquery.sessionOf
@@ -35,7 +37,7 @@ class VarselEndretRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val vedtaksperiodeId = UUID.fromString(packet["vedtaksperiode_id"].asText())
         val tittel = packet["varseltittel"].asText()
         val meldingOpprettet = packet["@opprettet"].asLocalDateTime()

diff --git a/src/main/kotlin/no/nav/helse/VedtaksperiodeBehandletRiver.kt b/src/main/kotlin/no/nav/helse/VedtaksperiodeBehandletRiver.kt
@@ -5,7 +5,9 @@ import com.github.navikt.tbd_libs.rapids_and_rivers.JsonMessage
 import com.github.navikt.tbd_libs.rapids_and_rivers.River
 import com.github.navikt.tbd_libs.rapids_and_rivers.asLocalDateTime
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageContext
+import com.github.navikt.tbd_libs.rapids_and_rivers_api.MessageMetadata
 import com.github.navikt.tbd_libs.rapids_and_rivers_api.RapidsConnection
+import io.micrometer.core.instrument.MeterRegistry
 import kotliquery.Session
 import kotliquery.queryOf
 import kotliquery.sessionOf
@@ -31,7 +33,7 @@ class VedtaksperiodeBehandletRiver(
         }.register(this)
     }
 
-    override fun onPacket(packet: JsonMessage, context: MessageContext) {
+    override fun onPacket(packet: JsonMessage, context: MessageContext, metadata: MessageMetadata, meterRegistry: MeterRegistry) {
         val json = objectMapper.readTree(packet.toJson())
         val behovId = UUID.fromString(json["@behovId"].asText())
         val vedtaksperiodeId = UUID.fromString(json["vedtaksperiodeId"].asText())