From 8b642794376b8eae40bcd08483dd19ebf6962679 Mon Sep 17 00:00:00 2001
From: Ingrid Gladheim <ingridgladheim@hotmail.com>
Date: Fri, 20 Sep 2024 14:40:05 +0200
Subject: [PATCH] Start consumer manglende medvirkning

---
 .../syfo/personstatus/infrastructure/kafka/KafkaModule.kt  | 7 +++++++
 .../ManglendeMedvirkningVurderingConsumer.kt               | 7 +++----
 2 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt
index 9207ea5a..1ef2112e 100644
--- a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt
+++ b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/KafkaModule.kt
@@ -13,6 +13,7 @@ import no.nav.syfo.oppfolgingstilfelle.kafka.launchKafkaTaskOppfolgingstilfelleP
 import no.nav.syfo.pdlpersonhendelse.kafka.launchKafkaTaskPersonhendelse
 import no.nav.syfo.personoppgavehendelse.kafka.launchKafkaTaskPersonoppgavehendelse
 import no.nav.syfo.personstatus.PersonoversiktStatusService
+import no.nav.syfo.personstatus.infrastructure.kafka.manglendemedvirkning.ManglendeMedvirkningVurderingConsumer
 import no.nav.syfo.personstatus.infrastructure.kafka.meroppfolging.SenOppfolgingKandidatStatusConsumer
 import no.nav.syfo.trengeroppfolging.kafka.launchTrengerOppfolgingConsumer
 
@@ -75,4 +76,10 @@ fun launchKafkaModule(
             applicationState = applicationState,
             kafkaEnvironment = environment.kafka,
         )
+
+    ManglendeMedvirkningVurderingConsumer(personoversiktStatusService = personoversiktStatusService)
+        .start(
+            applicationState = applicationState,
+            kafkaEnvironment = environment.kafka,
+        )
 }
diff --git a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumer.kt b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumer.kt
index d737bf09..fc956460 100644
--- a/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumer.kt
+++ b/src/main/kotlin/no/nav/syfo/personstatus/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumer.kt
@@ -3,7 +3,6 @@ package no.nav.syfo.personstatus.infrastructure.kafka.manglendemedvirkning
 import no.nav.syfo.ApplicationState
 import no.nav.syfo.personstatus.PersonoversiktStatusService
 import no.nav.syfo.personstatus.infrastructure.kafka.*
-import no.nav.syfo.personstatus.infrastructure.kafka.meroppfolging.KandidatStatusRecord
 import no.nav.syfo.util.configuredJacksonMapper
 import org.apache.kafka.clients.consumer.ConsumerConfig
 import org.apache.kafka.clients.consumer.ConsumerRecords
@@ -59,8 +58,8 @@ class ManglendeMedvirkningVurderingConsumer(
     }
 }
 
-class ManglendeMedvirkningVurderingRecordDeserializer : Deserializer<KandidatStatusRecord> {
+class ManglendeMedvirkningVurderingRecordDeserializer : Deserializer<VurderingRecord> {
     private val mapper = configuredJacksonMapper()
-    override fun deserialize(topic: String, data: ByteArray): KandidatStatusRecord =
-        mapper.readValue(data, KandidatStatusRecord::class.java)
+    override fun deserialize(topic: String, data: ByteArray): VurderingRecord =
+        mapper.readValue(data, VurderingRecord::class.java)
 }