chore: reformat sykmeldinger to new topic

navikt · Nov 25, 2024 · b104732 · b104732
1 parent 6a15871
commit b104732
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 6 deletions.
diff --git a/src/main/kotlin/no/nav/tsm/Application.kt b/src/main/kotlin/no/nav/tsm/Application.kt
@@ -14,5 +14,5 @@ fun main(args: Array<String>) {
 fun Application.module() {
     configureDependencyInjection()
     configureMonitoring()
-    configureConsumer(get())
+    configureConsumer(get(), get())
 }
diff --git a/src/main/kotlin/no/nav/tsm/plugins/Consumer.kt b/src/main/kotlin/no/nav/tsm/plugins/Consumer.kt
@@ -4,15 +4,16 @@ import io.ktor.server.application.Application
 import io.ktor.server.application.ApplicationStopping
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.launch
+import no.nav.tsm.reformat.sykmelding.SykmeldingReformatService
 import no.nav.tsm.sykmeldinger.input.SykmeldingInputConsumer
 import no.nav.tsm.sykmeldinger.kafka.SykmeldingConsumer
 
-fun Application.configureConsumer(sykmeldingConsumer: SykmeldingConsumer) {
+fun Application.configureConsumer(sykmeldingConsumer: SykmeldingConsumer, sykmeldingReformatService: SykmeldingReformatService) {
     val sykmeldingConsumerJob = launch(Dispatchers.IO) { sykmeldingConsumer.start() }
-    //val sykmeldingReformatJob = launch(Dispatchers.IO) { sykmeldingReformatService.start() }
+    val sykmeldingReformatJob = launch(Dispatchers.IO) { sykmeldingReformatService.start() }
 
     environment.monitor.subscribe(ApplicationStopping) {
-        //sykmeldingReformatJob.cancel()
+        sykmeldingReformatJob.cancel()
         sykmeldingConsumerJob.cancel()
     }
 }
diff --git a/src/main/kotlin/no/nav/tsm/plugins/DependencyInjection.kt b/src/main/kotlin/no/nav/tsm/plugins/DependencyInjection.kt
@@ -27,7 +27,7 @@ fun Application.configureDependencyInjection() {
         modules(
             environmentModule(),
             sykmeldingConsumer,
-            //sykmeldingReformatService
+            sykmeldingReformatService
         )
     }
 }

diff --git a/src/main/kotlin/no/nav/tsm/plugins/Environment.kt b/src/main/kotlin/no/nav/tsm/plugins/Environment.kt
@@ -12,7 +12,7 @@ class Environment(
     val okSykmeldingTopic: String = "teamsykmelding.ok-sykmelding",
     val avvistSykmeldingTopic: String = "teamsykmelding.avvist-sykmelding",
     val manuellSykmeldingTopic: String = "teamsykmelding.manuell-behandling-sykmelding",
-    val sykmeldingOutputTopic: String = "tsm.sykmelding-raw",
+    val sykmeldingOutputTopic: String = "tsm.sykmeldinger-input",
     val teamsykmeldingSykmeldingTopic: String = "tsm.teamsykmelding-sykmeldinger",
     val cluster: String = getEnvVar("NAIS_CLUSTER_NAME")
 )