Implement async processing with delay in opprettArbeidsforhold

Added asynchronous handling using `Schedulers.boundedElastic()` to the `opprettArbeidsforhold` method. Introduced a 1-second delay for each status emission to manage downstream processing.
navikt · Oct 14, 2024 · bae72b1 · bae72b1
1 parent a43cfd2
commit bae72b1
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/...in/java/no/nav/testnav/levendearbeidsforholdansettelse/service/ArbeidsforholdService.java b/...in/java/no/nav/testnav/levendearbeidsforholdansettelse/service/ArbeidsforholdService.java
@@ -13,6 +13,7 @@
 import org.springframework.http.HttpStatusCode;
 import org.springframework.stereotype.Service;
 import reactor.core.publisher.Flux;
+import reactor.core.scheduler.Schedulers;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
@@ -53,7 +54,15 @@ public Flux<Arbeidsforhold> getArbeidsforhold(String ident) {
     public Flux<HttpStatusCode> opprettArbeidsforhold(KanAnsettesDTO kanAnsettes, String yrke,
                                                       String arbeidsforholdstype, Integer stillingsprosent) {
 
-        return aaregConsumer.opprettArbeidsforhold(lagArbeidsforhold(kanAnsettes, yrke, arbeidsforholdstype, stillingsprosent));
+        return aaregConsumer.opprettArbeidsforhold(lagArbeidsforhold(kanAnsettes, yrke, arbeidsforholdstype, stillingsprosent))
+                .publishOn(Schedulers.boundedElastic())
+                .doOnNext(status -> {
+                    try {
+                        Thread.sleep(1000);
+                    } catch (InterruptedException e) {
+                        throw new RuntimeException(e);
+                    }
+                });
     }
 
     /**