Class ReactiveResilience4JCircuitBreaker

java.lang.Object

org.springframework.cloud.circuitbreaker.resilience4j.ReactiveResilience4JCircuitBreaker

All Implemented Interfaces:

org.springframework.cloud.client.circuitbreaker.ReactiveCircuitBreaker

public class ReactiveResilience4JCircuitBreaker
extends Object
implements org.springframework.cloud.client.circuitbreaker.ReactiveCircuitBreaker

Author:

Ryan Baxter, Thomas Vitale, 荒, Yavor Chamov

Constructor Summary

Constructors

Constructor

Description

ReactiveResilience4JCircuitBreaker(String id, String groupName, Resilience4JConfigBuilder.Resilience4JCircuitBreakerConfiguration config, io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry circuitBreakerRegistry, io.github.resilience4j.timelimiter.TimeLimiterRegistry timeLimiterRegistry, Optional<org.springframework.cloud.client.circuitbreaker.Customizer<io.github.resilience4j.circuitbreaker.CircuitBreaker>> circuitBreakerCustomizer, @Nullable ReactiveResilience4jBulkheadProvider bulkheadProvider, boolean disableTimeLimiter)

Method Summary

Modifier and Type	Method	Description
<T> reactor.core.publisher.Flux<T>	run(reactor.core.publisher.Flux<T> toRun, @Nullable Function<Throwable, reactor.core.publisher.Flux<T>> fallback)
<T> reactor.core.publisher.Mono<T>	run(reactor.core.publisher.Mono<T> toRun, @Nullable Function<Throwable, reactor.core.publisher.Mono<T>> fallback)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.cloud.client.circuitbreaker.ReactiveCircuitBreaker

run, run

Constructor Details

ReactiveResilience4JCircuitBreaker

public ReactiveResilience4JCircuitBreaker(String id,
 String groupName,
 Resilience4JConfigBuilder.Resilience4JCircuitBreakerConfiguration config,
 io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry circuitBreakerRegistry,
 io.github.resilience4j.timelimiter.TimeLimiterRegistry timeLimiterRegistry,
 Optional<org.springframework.cloud.client.circuitbreaker.Customizer<io.github.resilience4j.circuitbreaker.CircuitBreaker>> circuitBreakerCustomizer,
 @Nullable ReactiveResilience4jBulkheadProvider bulkheadProvider,
 boolean disableTimeLimiter)

Method Details

run

public <T> reactor.core.publisher.Mono<T> run(reactor.core.publisher.Mono<T> toRun,
 @Nullable Function<Throwable, reactor.core.publisher.Mono<T>> fallback)

Specified by:

run in interface org.springframework.cloud.client.circuitbreaker.ReactiveCircuitBreaker

run

public <T> reactor.core.publisher.Flux<T> run(reactor.core.publisher.Flux<T> toRun,
 @Nullable Function<Throwable, reactor.core.publisher.Flux<T>> fallback)

Specified by:

run in interface org.springframework.cloud.client.circuitbreaker.ReactiveCircuitBreaker