Start consumer manglende medvirkning

navikt · Sep 20, 2024 · 8b64279 · 8b64279
1 parent 5947e7f
commit 8b64279
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 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
@@ -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/...status/infrastructure/kafka/manglendemedvirkning/ManglendeMedvirkningVurderingConsumer.kt b/...status/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)
 }