Я тестировал свой код для части обработки ошибок. Похоже, что она работает не так, как ожидалось. Я разбил фрагмент кода, как показано ниже. Общие добавления - повторить 5 раз, когда есть исключение. Для простоты я написалметод, чтобы вызвать исключение NPE и добавил обработчик ошибок. Может кто-нибудь объяснить, что не так.
public static void main(String[] args) {
Mono.just( errorDemo() )
.retry(5)
.doOnError( e -> log.error( "Error {}", e.getStackTrace() ) )
.doOnSuccess( e -> log.info( "done" ) );
}
public static Mono<Void> errorDemo() {
return Mono.error( NullPointerException::new ); // throwing back
exception to calling method
}