Я смотрю на пример Spring Cloud Circuit Breaker в отношении использования Reactive API. Я понимаю основы и то, как работает резервный механизм для WebClient
, но не могу понять, как реализовать отказоустойчивое решение для разомкнутого автоматического выключателя.
Это пример метода, который я хотел бы сделать «безотказным» (взято из статьи).
public Mono<String> slow() {
return webClient.get().uri("/slow").retrieve()
.bodyToMono(String.class).transform(it -> {
CircuitBreaker cb = cbFactory.create("slow");
return cb.run(it, throwable ->
Mono.just("fallback"));
});
}
Любая помощь или понимание этого очень ценится.