From 8bcc38eb602c3e640f4af3ef35b714d8c43c47e9 Mon Sep 17 00:00:00 2001 From: Nils Martin Sande Date: Thu, 3 Oct 2024 09:20:14 +0200 Subject: [PATCH] Ryddet litt i bekreftelse varsel topology --- .../minsideoppgaver/applogic/Topology.kt | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/apps/bekreftelse-min-side-oppgaver/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/bekreftelse/minsideoppgaver/applogic/Topology.kt b/apps/bekreftelse-min-side-oppgaver/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/bekreftelse/minsideoppgaver/applogic/Topology.kt index f6ee8119..4f11e8d8 100644 --- a/apps/bekreftelse-min-side-oppgaver/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/bekreftelse/minsideoppgaver/applogic/Topology.kt +++ b/apps/bekreftelse-min-side-oppgaver/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/bekreftelse/minsideoppgaver/applogic/Topology.kt @@ -23,7 +23,8 @@ import java.util.* typealias InternalStateStore = KeyValueStore -fun ProcessorContext<*, *>.getStateStore(stateStoreName: StateStoreName ): InternalStateStore = getStateStore(stateStoreName.value) +fun ProcessorContext<*, *>.getStateStore(stateStoreName: StateStoreName): InternalStateStore = + getStateStore(stateStoreName.value) private val logger = LoggerFactory.getLogger("bekreftelse.varsler.topology") @@ -46,7 +47,7 @@ fun StreamsBuilder.applicationTopology( stream( kafkaTopics.bekreftelseHendelseTopic, Consumed.with(Serdes.Long(), BekreftelseHendelseSerde()) ).mapWithContext("bekreftelse-hendelse-mottatt", stateStoreName.value) { hendelse -> - val store: KeyValueStore = getStateStore(stateStoreName.value) + val store = getStateStore(stateStoreName) val tilstand = store[hendelse.periodeId] if (tilstand == null) { logger.warn( @@ -64,9 +65,11 @@ fun StreamsBuilder.applicationTopology( } meldinger } - }.flatMapValues { _, meldinger -> meldinger }.mapKeyAndValue("map_til_utgaaende") { _, melding -> - melding.varselId.toString() to melding.value - }.to(kafkaTopics.tmsOppgaveTopic, Produced.with(Serdes.String(), Serdes.String())) + } + .flatMapValues { _, meldinger -> meldinger } + .mapKeyAndValue("map_til_utgaaende") { _, melding -> + melding.varselId.toString() to melding.value + }.to(kafkaTopics.tmsOppgaveTopic, Produced.with(Serdes.String(), Serdes.String())) return build() } \ No newline at end of file