Deaktiverer ArbeidssokerperiodeScheduler midlertidig

navikt · Nov 7, 2023 · 4ae3325 · 4ae3325
1 parent 57197c4
commit 4ae3325
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 6 deletions.
diff --git a/...av/fo/veilarbregistrering/arbeidssoker/perioder/scheduler/ArbeidssokerperiodeScheduler.kt b/...av/fo/veilarbregistrering/arbeidssoker/perioder/scheduler/ArbeidssokerperiodeScheduler.kt
@@ -10,7 +10,7 @@ class ArbeidssokerperiodeScheduler(
     private val arbeidssokerperiodeService: ArbeidssokerperiodeService,
     private val arbeidssokerperiodeProducer: ArbeidssokerperiodeProducer,
 ) {
-    // @Scheduled(cron = "* * * * * *")
+    @Scheduled(cron = "HVERT_TIENDE_SEKUND")
     fun start() {
         if (!leaderElectionClient.isLeader) {
             return
@@ -28,6 +28,10 @@ class ArbeidssokerperiodeScheduler(
 
         arbeidssokerperiodeProducer.publiserArbeidssokerperioder(arbeidssokerperioder)
 
-        // arbeidssokerperiodeService.settArbeidssokerperioderSomOverfort(arbeidssokerperioder.map { it.id })
+        arbeidssokerperiodeService.settArbeidssokerperioderSomOverfort(arbeidssokerperioder.map { it.id })
+    }
+
+    companion object {
+        const val HVERT_TIENDE_SEKUND = "0/10 * * * * *"
     }
 }
diff --git a/...kotlin/no/nav/fo/veilarbregistrering/db/arbeidssoker/ArbeidssokerperiodeRepositoryImpl.kt b/...kotlin/no/nav/fo/veilarbregistrering/db/arbeidssoker/ArbeidssokerperiodeRepositoryImpl.kt
@@ -70,7 +70,7 @@ class ArbeidssokerperiodeRepositoryImpl(private val db: NamedParameterJdbcTempla
     }
 
     override fun hentNesteArbeidssokerperioder(): List<ArbeidssokerperiodeDto> {
-        val sql = "SELECT * FROM $ARBEIDSSOKERPERIODE_TABELL WHERE overfort_kafka IS FALSE ORDER BY fra_og_med LIMIT 1"
+        val sql = "SELECT * FROM $ARBEIDSSOKERPERIODE_TABELL WHERE overfort_kafka IS FALSE ORDER BY fra_og_med LIMIT 50"
         return db.query(sql, arbeidssokerperiodeMapper)
     }
 

diff --git a/...gistrering/registrering/publisering/scheduler/PubliseringAvRegistreringEventsScheduler.kt b/...gistrering/registrering/publisering/scheduler/PubliseringAvRegistreringEventsScheduler.kt
@@ -11,9 +11,9 @@ import org.springframework.scheduling.annotation.Scheduled
 class PubliseringAvRegistreringEventsScheduler(
     private val publiseringAvEventsService: PubliseringAvEventsService,
     private val leaderElectionClient: LeaderElectionClient,
-    private val unleashClient: UnleashClient
+    private val unleashClient: UnleashClient,
 ) {
-    @Scheduled(cron = HVERT_TIENDE_SEKUND)
+    // @Scheduled(cron = HVERT_TIENDE_SEKUND)
     fun publiserRegistreringEvents() {
         try {
             CallId.leggTilCallId()
@@ -34,4 +34,4 @@ class PubliseringAvRegistreringEventsScheduler(
         private val LOG = LoggerFactory.getLogger(PubliseringAvRegistreringEventsScheduler::class.java)
         const val HVERT_TIENDE_SEKUND = "0/10 * * * * *"
     }
-}
+}