Bugfix/gjenopprett gruppe backpressure (#3961)

Author: krharum

apps/dolly-backend/src/main/java/no/nav/dolly/DollyBackendApplicationStarter.java

@@ -12,4 +12,4 @@ public static void main(String[] args) {
                 .initializers(new NaisEnvironmentApplicationContextInitializer())
                 .run(args);
     }
-}
+}

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/ConsumerStatus.java

@@ -27,9 +27,9 @@ public abstract class ConsumerStatus {
     public Mono<Map<String, TestnavStatusResponse>> checkStatus(WebClient webClient) {
 
         return checkConsumerStatus(
-                        serviceUrl() + LIVENESS_ENDPOINT,
-                        serviceUrl() + READINESS_ENDPOINT,
-                        webClient)
+                serviceUrl() + LIVENESS_ENDPOINT,
+                serviceUrl() + READINESS_ENDPOINT,
+                webClient)
                 .map(consumerResponce -> Map.of(consumerName(), consumerResponce))
                 .flatMap(consumerStatus ->
                         webClient

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/command/ArbeidsforholdGetCommand.java

@@ -50,6 +50,7 @@ public Mono<ArbeidsforholdRespons> call() {
                         .miljoe(miljoe)
                         .build())
                 .doOnError(WebClientError.logTo(log))
+                .retryWhen(WebClientError.is5xxException())
                 .onErrorResume(error -> Mono.just(ArbeidsforholdRespons.builder()
                         .miljoe(miljoe)
                         .error(error)

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/command/ArbeidsforholdPostCommand.java

@@ -41,6 +41,7 @@ public Flux<ArbeidsforholdRespons> call() {
                         .miljoe(miljoe)
                         .build())
                 .doOnError(WebClientError.logTo(log))
+                .retryWhen(WebClientError.is5xxException())
                 .onErrorResume(error -> Flux.just(ArbeidsforholdRespons.builder()
                         .miljoe(miljoe)
                         .error(error)

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/aareg/command/ArbeidsforholdPutCommand.java

@@ -46,6 +46,7 @@ public Flux<ArbeidsforholdRespons> call() {
                         .miljoe(miljoe)
                         .build())
                 .doOnError(WebClientError.logTo(log))
+                .retryWhen(WebClientError.is5xxException())
                 .onErrorResume(error -> Flux.just(ArbeidsforholdRespons.builder()
                         .miljoe(miljoe)
                         .error(error)

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arbeidsplassencv/command/ArbeidsplassenDeleteCVCommand.java

@@ -42,6 +42,7 @@ public Mono<ArbeidsplassenCVStatusDTO> call() {
                         throwable -> !(throwable instanceof WebClientResponseException.NotFound),
                         WebClientError.logTo(log))
 
+                .retryWhen(WebClientError.is5xxException())
                 .onErrorResume(WebClientResponseException.NotFound.class::isInstance, throwable -> Mono.empty());
     }
 

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arbeidsplassencv/command/ArbeidsplassenGodtaHjemmelCommand.java

@@ -44,6 +44,7 @@ public Mono<ArbeidsplassenCVStatusDTO> call() {
                         .build())
                 .doOnError(WebClientError.logTo(log))
 
+                .retryWhen(WebClientError.is5xxException())
                 .onErrorResume(throwable -> ArbeidsplassenCVStatusDTO.of(WebClientError.describe(throwable), uuid));
     }
 }

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arbeidsplassencv/command/ArbeidsplassenGodtaVilkaarCommand.java

@@ -44,6 +44,7 @@ public Mono<ArbeidsplassenCVStatusDTO> call() {
                         .build())
                 .doOnError(WebClientError.logTo(log))
 
+                .retryWhen(WebClientError.is5xxException())
                 .onErrorResume(throwable -> ArbeidsplassenCVStatusDTO.of(WebClientError.describe(throwable), uuid));
     }
 }

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arbeidsplassencv/command/ArbeidsplassenPostPersonCommand.java

@@ -43,7 +43,7 @@ public Mono<ArbeidsplassenCVStatusDTO> call() {
                         .uuid(uuid)
                         .build())
                 .doOnError(WebClientError.logTo(log))
-
+                .retryWhen(WebClientError.is5xxException())
                 .onErrorResume(throwable -> ArbeidsplassenCVStatusDTO.of(WebClientError.describe(throwable), uuid));
     }
 

apps/dolly-backend/src/main/java/no/nav/dolly/bestilling/arbeidsplassencv/command/ArbeidsplassenPutCVCommand.java

@@ -48,6 +48,7 @@ public Mono<ArbeidsplassenCVStatusDTO> call() {
                         .build())
                 .doOnError(WebClientError.logTo(log))
 
+                .retryWhen(WebClientError.is5xxException())
                 .onErrorResume(throwable -> ArbeidsplassenCVStatusDTO.of(WebClientError.describe(throwable), uuid));
     }