Test virtual threads

navikt · Oct 18, 2024 · ae27c71 · ae27c71
1 parent 30b1315
commit ae27c71
Show file tree

Hide file tree

Showing 11 changed files with 117 additions and 59 deletions.
diff --git a/...jening/brev/external/spring/BrevConfig.kt → .../brev/external/spring/BrevClientConfig.kt b/...jening/brev/external/spring/BrevConfig.kt → .../brev/external/spring/BrevClientConfig.kt
@@ -10,7 +10,7 @@ import org.springframework.context.annotation.Configuration
 import pensjon.opptjening.azure.ad.client.TokenProvider
 
 @Configuration
-class BrevConfig {
+class BrevClientConfig {
 
     @Bean
     fun brevClient(

diff --git a/...opptjening/omsorgsopptjening/bestem/pensjonsopptjening/brev/model/BrevProcessingThread.kt b/...opptjening/omsorgsopptjening/bestem/pensjonsopptjening/brev/model/BrevProcessingThread.kt
@@ -1,17 +1,12 @@
 package no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.brev.model
 
 import io.getunleash.Unleash
-import jakarta.annotation.PostConstruct
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.brev.metrics.BrevProcessingMetricsFeilmåling
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.brev.metrics.BrevProcessingMetrikker
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.config.DatasourceReadinessCheck
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.unleash.NavUnleashConfig
 import org.slf4j.LoggerFactory
-import org.springframework.context.annotation.Profile
-import org.springframework.stereotype.Component
 
-@Component
-@Profile("dev-gcp", "prod-gcp", "kafkaIntegrationTest")
 class BrevProcessingThread(
     private val service: BrevService,
     private val unleash: Unleash,
@@ -24,11 +19,8 @@ class BrevProcessingThread(
         private val log = LoggerFactory.getLogger(this::class.java)!!
     }
 
-    @PostConstruct
-    fun init() {
-        val name = "prosesser-brev-thread"
-        log.info("Starting new thread:$name to process brev")
-        Thread(this, name).start()
+    init {
+        log.info("Starting new thread to process brev")
     }
 
     override fun run() {

diff --git a/...on/opptjening/omsorgsopptjening/bestem/pensjonsopptjening/brev/model/spring/BrevConfig.kt b/...on/opptjening/omsorgsopptjening/bestem/pensjonsopptjening/brev/model/spring/BrevConfig.kt
@@ -0,0 +1,37 @@
+package no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.brev.model.spring
+
+import io.getunleash.Unleash
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.brev.metrics.BrevProcessingMetricsFeilmåling
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.brev.metrics.BrevProcessingMetrikker
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.brev.model.BrevProcessingThread
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.brev.model.BrevService
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.config.DatasourceReadinessCheck
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Profile
+
+@Configuration
+class BrevConfig {
+
+    @Bean
+    @Profile("dev-gcp", "prod-gcp", "kafkaIntegrationTest")
+    fun brevProcessingThread(
+        service: BrevService,
+        unleash: Unleash,
+        brevProcessingMetricsMåling: BrevProcessingMetrikker,
+        brevProcessingMetricsFeilmåling: BrevProcessingMetricsFeilmåling,
+        datasourceReadinessCheck: DatasourceReadinessCheck,
+    ): Runnable {
+        return Thread.ofVirtual()
+            .name("prosesser-brev-thread")
+            .start(
+                BrevProcessingThread(
+                    service = service,
+                    unleash = unleash,
+                    brevProcessingMetricsMåling = brevProcessingMetricsMåling,
+                    brevProcessingMetricsFeilmåling = brevProcessingMetricsFeilmåling,
+                    datasourceReadinessCheck = datasourceReadinessCheck
+                )
+            )
+    }
+}
diff --git a/...opptjening/bestem/pensjonsopptjening/godskriv/model/GodskrivOpptjeningProcessingThread.kt b/...opptjening/bestem/pensjonsopptjening/godskriv/model/GodskrivOpptjeningProcessingThread.kt
@@ -1,7 +1,6 @@
 package no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.godskriv.model
 
 import io.getunleash.Unleash
-import jakarta.annotation.PostConstruct
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.config.DatasourceReadinessCheck
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.godskriv.metrics.GodskrivProcessingMetricsFeilmåling
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.godskriv.metrics.GodskrivProcessingMetrikker
@@ -20,11 +19,8 @@ internal class GodskrivOpptjeningProcessingThread(
         private val log = LoggerFactory.getLogger(this::class.java)!!
     }
 
-    @PostConstruct
-    fun init() {
-        val name = "prosesser-godskriv-opptjening-thread"
-        log.info("Starting new thread:$name to process godskriv opptjening")
-        Thread(this, name).start()
+    init {
+        log.info("Starting new thread to process godskriv opptjening")
     }
 
     override fun run() {

diff --git a/...rgsopptjening/bestem/pensjonsopptjening/godskriv/model/spring/GodskrivOpptjeningConfig.kt b/...rgsopptjening/bestem/pensjonsopptjening/godskriv/model/spring/GodskrivOpptjeningConfig.kt
@@ -58,13 +58,17 @@ class GodskrivOpptjeningConfig {
         godskrivProcessingMetricsFeilmåling: GodskrivProcessingMetricsFeilmåling,
         datasourceReadinessCheck: DatasourceReadinessCheck,
     ): Runnable {
-        return GodskrivOpptjeningProcessingThread(
-            service = service,
-            unleash = unleash,
-            godskrivProcessingMetricsMåling = godskrivProcessingMetricsMåling,
-            godskrivProcessingMetricsFeilmåling = godskrivProcessingMetricsFeilmåling,
-            datasourceReadinessCheck = datasourceReadinessCheck
-        )
+        return Thread.ofVirtual()
+            .name("prosesser-godskriv-opptjening-thread")
+            .start(
+                GodskrivOpptjeningProcessingThread(
+                    service = service,
+                    unleash = unleash,
+                    godskrivProcessingMetricsMåling = godskrivProcessingMetricsMåling,
+                    godskrivProcessingMetricsFeilmåling = godskrivProcessingMetricsFeilmåling,
+                    datasourceReadinessCheck = datasourceReadinessCheck
+                )
+            )
     }
 
     @Bean

diff --git a/...jening/bestem/pensjonsopptjening/kontrollbehandling/KontrollbehandlingProcessingThread.kt b/...jening/bestem/pensjonsopptjening/kontrollbehandling/KontrollbehandlingProcessingThread.kt
@@ -12,12 +12,9 @@ class KontrollbehandlingProcessingThread(
 ) : Runnable {
 
     init {
-        val name = "prosesser-persongrunnlag-kontrollbehandling-thread"
-        log.info("Starting new thread:$name to process kontrollbehandlinger")
-        Thread(this, name).start()
+        log.info("Starting new thread to process kontrollbehandlinger")
     }
 
-
     companion object {
         private val log = LoggerFactory.getLogger(this::class.java)!!
     }

diff --git a/...g/omsorgsopptjening/bestem/pensjonsopptjening/kontrollbehandling/spring/KontrollConfig.kt b/...g/omsorgsopptjening/bestem/pensjonsopptjening/kontrollbehandling/spring/KontrollConfig.kt
@@ -60,16 +60,20 @@ class KontrollConfig {
     }
 
     @Bean
-    @Profile("dev-gcp", "prod-gcp")
+    @Profile("dev-gcp", "prod-gcp","kafkaIntegrationTest")
     fun kontrollProcessingThread(
         service: KontrollbehandlingProcessingService,
         unleash: Unleash,
         datasourceReadinessCheck: DatasourceReadinessCheck,
     ): Runnable {
-        return KontrollbehandlingProcessingThread(
-            service = service,
-            unleash = unleash,
-            datasourceReadinessCheck = datasourceReadinessCheck
-        )
+        return Thread.ofVirtual()
+            .name("prosesser-persongrunnlag-kontrollbehandling-thread")
+            .start(
+                KontrollbehandlingProcessingThread(
+                    service = service,
+                    unleash = unleash,
+                    datasourceReadinessCheck = datasourceReadinessCheck
+                )
+            )
     }
 }
diff --git a/...ning/omsorgsopptjening/bestem/pensjonsopptjening/oppgave/model/OppgaveProcessingThread.kt b/...ning/omsorgsopptjening/bestem/pensjonsopptjening/oppgave/model/OppgaveProcessingThread.kt
@@ -1,17 +1,13 @@
 package no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.oppgave.model
 
 import io.getunleash.Unleash
-import jakarta.annotation.PostConstruct
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.config.DatasourceReadinessCheck
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.oppgave.metrics.OppgaveProcessingMetricsFeilmåling
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.oppgave.metrics.OppgaveProcessingMetrikker
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.unleash.NavUnleashConfig
 import org.slf4j.LoggerFactory
-import org.springframework.context.annotation.Profile
-import org.springframework.stereotype.Component
 
-@Component
-@Profile("dev-gcp", "prod-gcp", "kafkaIntegrationTest")
+
 class OppgaveProcessingThread(
     private val service: OppgaveService,
     private val unleash: Unleash,
@@ -24,11 +20,8 @@ class OppgaveProcessingThread(
         private val log = LoggerFactory.getLogger(this::class.java)!!
     }
 
-    @PostConstruct
-    fun init() {
-        val name = "prosesser-oppgave-thread"
-        log.info("Starting new thread:$name to process oppgaver")
-        Thread(this, name).start()
+    init {
+        log.info("Starting new thread to process oppgaver")
     }
 
     override fun run() {

diff --git a/...tjening/omsorgsopptjening/bestem/pensjonsopptjening/oppgave/model/spring/OppgaveConfig.kt b/...tjening/omsorgsopptjening/bestem/pensjonsopptjening/oppgave/model/spring/OppgaveConfig.kt
@@ -0,0 +1,37 @@
+package no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.oppgave.model.spring
+
+import io.getunleash.Unleash
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.config.DatasourceReadinessCheck
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.oppgave.metrics.OppgaveProcessingMetricsFeilmåling
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.oppgave.metrics.OppgaveProcessingMetrikker
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.oppgave.model.OppgaveProcessingThread
+import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.oppgave.model.OppgaveService
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.context.annotation.Profile
+
+@Configuration
+class OppgaveConfig {
+
+    @Bean
+    @Profile("dev-gcp", "prod-gcp", "kafkaIntegrationTest")
+    fun oppgaveProcessingThread(
+        service: OppgaveService,
+        unleash: Unleash,
+        oppgaveProcessingMetricsMåling: OppgaveProcessingMetrikker,
+        oppgaveProcessingMetricsFeilmåling: OppgaveProcessingMetricsFeilmåling,
+        datasourceReadinessCheck: DatasourceReadinessCheck,
+    ): Runnable {
+        return Thread.ofVirtual()
+            .name("prosesser-oppgave-thread")
+            .start(
+                OppgaveProcessingThread(
+                    service = service,
+                    unleash = unleash,
+                    oppgaveProcessingMetricsMåling = oppgaveProcessingMetricsMåling,
+                    oppgaveProcessingMetricsFeilmåling = oppgaveProcessingMetricsFeilmåling,
+                    datasourceReadinessCheck = datasourceReadinessCheck
+                )
+            )
+    }
+}
diff --git a/...g/bestem/pensjonsopptjening/persongrunnlag/model/PersongrunnlagMeldingProcessingThread.kt b/...g/bestem/pensjonsopptjening/persongrunnlag/model/PersongrunnlagMeldingProcessingThread.kt
@@ -1,14 +1,11 @@
 package no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.persongrunnlag.model
 
 import io.getunleash.Unleash
-import jakarta.annotation.PostConstruct
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.config.DatasourceReadinessCheck
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.omsorgsarbeid.metrics.OmsorgsarbeidProcessingMetricsFeilmåling
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.omsorgsarbeid.metrics.OmsorgsarbeidProcessingMetrikker
 import no.nav.pensjon.opptjening.omsorgsopptjening.bestem.pensjonsopptjening.unleash.NavUnleashConfig
 import org.slf4j.LoggerFactory
-import org.springframework.context.annotation.Profile
-import org.springframework.stereotype.Component
 
 class PersongrunnlagMeldingProcessingThread(
     private val service: PersongrunnlagMeldingProcessingService,
@@ -22,11 +19,8 @@ class PersongrunnlagMeldingProcessingThread(
         private val log = LoggerFactory.getLogger(this::class.java)!!
     }
 
-    @PostConstruct
-    fun init() {
-        val name = "prosesser-persongrunnlag-melding-thread"
-        log.info("Starting new thread:$name to process persongrunnlag")
-        Thread(this, name).start()
+    init {
+        log.info("Starting new thread to process persongrunnlag")
     }
 
     override fun run() {

diff --git a/...sopptjening/bestem/pensjonsopptjening/persongrunnlag/model/spring/PersongrunnlagConfig.kt b/...sopptjening/bestem/pensjonsopptjening/persongrunnlag/model/spring/PersongrunnlagConfig.kt
@@ -72,13 +72,17 @@ class PersongrunnlagConfig {
         omsorgsarbeidMetricsFeilmåling: OmsorgsarbeidProcessingMetricsFeilmåling,
         datasourceReadinessCheck: DatasourceReadinessCheck,
     ): Runnable {
-        return PersongrunnlagMeldingProcessingThread(
-            service = service,
-            unleash = unleash,
-            omsorgsarbeidMetricsMåling = omsorgsarbeidMetricsMåling,
-            omsorgsarbeidMetricsFeilmåling = omsorgsarbeidMetricsFeilmåling,
-            datasourceReadinessCheck = datasourceReadinessCheck
-        )
+        return Thread.ofVirtual()
+            .name("prosesser-persongrunnlag-melding-thread")
+            .start(
+                PersongrunnlagMeldingProcessingThread(
+                    service = service,
+                    unleash = unleash,
+                    omsorgsarbeidMetricsMåling = omsorgsarbeidMetricsMåling,
+                    omsorgsarbeidMetricsFeilmåling = omsorgsarbeidMetricsFeilmåling,
+                    datasourceReadinessCheck = datasourceReadinessCheck
+                )
+            )
     }
 
     @Bean