Webclient retryWhen and onErrorResume mutually exclusive?

Question

I am trying to implement a retry on specific exception but I could not make it work using the following:

    return client
        .sendWebhook(request, url)
        .exchangeToMono(
            response -> {
              final HttpStatus status = response.statusCode();
              return response
                  .bodyToMono(String.class)
                  .defaultIfEmpty(StringUtils.EMPTY)
                  .map(
                      body -> {
                        if (status.is2xxSuccessful()) {
                          log.info("HTTP_SUCCESS[{}][{}] body[{}]", functionName, company, body);
                          return ResponseEntity.ok().body(body);
                        } else {
                          log.warn(
                              format(
                                  "HTTP_ERROR[%s][%s] status[%s] body[%s]",
                                  functionName, company, status, body));
                          return status.is4xxClientError()
                              ? ResponseEntity.badRequest().body(body)
                              : ResponseEntity.internalServerError().body(body);
                        }
                      });
            })
        .retryWhen(
            Retry.backoff(1, Duration.ofSeconds(1))
                .filter(
                    err -> {
                      if (err instanceof PrematureCloseException) {
                        log.warn("PrematureCloseException detected retrying.");
                        return true;
                      }
                      return false;
                    }))
        .onErrorResume(
            ex -> {
              log.warn(
                  format(
                      "HTTP_ERROR[%s][%s] errorInternal[%s]",
                      functionName, company, ex.getMessage()));
              return Mono.just(ResponseEntity.internalServerError().body(ex.getMessage()));
            });

It seems that the retry is never getting called on PrematureCloseException.

https://stackoverflow.com/a/64451287/2280259 – isank-a Jun 28 '22 at 20:04 — isank-a, Jun 28 '22 at 20:04

score 0 · Answer 1 · answered Jun 29 '22 at 10:55

Resolved, it was not working because of rootCause

Retry.backoff(3, Duration.ofMillis(500))
        .filter(
            ex -> {
              if (ExceptionUtils.getRootCause(ex) instanceof PrematureCloseException) {
                log.info(
                    "HTTP_RETRY[{}][{}] PrematureClose detected retrying", functionName, company);
                return true;
              }
              return false;
            });

Webclient retryWhen and onErrorResume mutually exclusive?

1 Answers1