From 666c7c8c15f49a6753fe60a577e7691a5fb7d3e8 Mon Sep 17 00:00:00 2001 From: Hans Petter Simonsen Date: Thu, 19 Dec 2024 10:52:15 +0100 Subject: [PATCH] Skriv DuplikatMeldingFeil til aktivitetskort-feil-topic (#898) --- .../aktivitetskort/AktivitetskortConsumer.kt | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/AktivitetskortConsumer.kt b/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/AktivitetskortConsumer.kt index d5a45bda2..ee6ae4251 100644 --- a/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/AktivitetskortConsumer.kt +++ b/src/main/kotlin/no/nav/veilarbaktivitet/aktivitetskort/AktivitetskortConsumer.kt @@ -27,7 +27,7 @@ import java.util.* @Service @ToString(of = ["aktivitetskortService"]) -open class AktivitetskortConsumer ( +class AktivitetskortConsumer ( private val aktivitetskortService: AktivitetskortService, private val kasseringsService: KasseringsService, private val feilProducer: AktivitetsKortFeilProducer, @@ -62,12 +62,11 @@ open class AktivitetskortConsumer ( bestilling.getAktivitetskortId() ) behandleBestilling(bestilling) - } catch (e: DuplikatMeldingFeil) { - ConsumeStatus.OK } catch (e: AktivitetsKortFunksjonellException) { val logMedPassendeNivå: (String, String?, Long, Int) -> Unit = when(e) { is ManglerOppfolgingsperiodeFeil -> log::warn is UlovligEndringFeil -> log::warn + is DuplikatMeldingFeil -> log::warn else -> log::error } logMedPassendeNivå( @@ -152,7 +151,7 @@ data class TraceFields( val source: MessageSource ) { constructor(messageId: UUID, source: String?) - : this(messageId, MessageSource.values().find { it.name == source } ?: MessageSource.UNKNOWN) + : this(messageId, MessageSource.entries.find { it.name == source } ?: MessageSource.UNKNOWN) } fun Long.toLocalDateTimeDefaultZone() = LocalDateTime.ofInstant(Instant.ofEpochMilli(this), ZoneId.systemDefault()) \ No newline at end of file