Проблема обработки исключений в реакторе проекта, а также повторная попытка неудачной транзакции - PullRequest
0 голосов
/ 24 декабря 2018

Я тестировал свой код для части обработки ошибок. Похоже, что она работает не так, как ожидалось. Я разбил фрагмент кода, как показано ниже. Общие добавления - повторить 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
}

1 Ответ

0 голосов
/ 26 декабря 2018

Вы должны подписаться на свой Mono.Ничего не произойдет, если вы не подпишетесь.

Вы можете добавить .block() для вашего примера.

...