Examples
Examples of resilience4j-reactor
Decorate Mono or Flux with a CircuitBreaker
The following example shows how to decorate a Mono by using the custom Reactor operator. Flux is also supported.
The CircuitBreakerOperator
checks if a downstream subscriber/observer can acquire a permission to subscribe to an upstream Publisher. If the CircuitBreaker is OPEN, the CircuitBreakerOperator emits a CallNotPermittedException
to the downstream subscriber.
CircuitBreaker circuitBreaker = CircuitBreaker.ofDefaults("name");
Mono.fromCallable(backendService::doSomething)
.compose(CircuitBreakerOperator.of(circuitBreaker))
Decorate Mono or Flux with a RateLimiter
The following example shows how to decorate a Mono by using the custom Reactor operator. Flux is also supported.
The RateLimiterOperator
checks if a downstream subscriber/observer can acquire a permission to subscribe to an upstream Publisher. If the rate limit is exceeded, the RateLimiterOperator emits a RequestNotPermitted
to the downstream subscriber.
RateLimiter rateLimiter = RateLimiter.ofDefaults("name");
Mono.fromCallable(backendService::doSomething)
.compose(RateLimiterOperator.of(rateLimiter))
Decorate Mono or Flux with a Bulkhead
The following example shows how to decorate a Mono by using the custom Reactor operator. Flux is also supported.
The BulkheadOperator
checks if a downstream subscriber/observer can acquire a permission to subscribe to an upstream Publisher. If the Bulhead is full, the BulkheadOperator emits a BulkheadFullException
to the downstream subscriber.
Bulkhead bulkhead = Bulkhead.ofDefaults("name");
Mono.fromCallable(backendService::doSomething)
.compose(BulkheadOperator.of(bulkhead));
Decorate Mono or Flux with Retry
Retry retry = Retry.ofDefaults("backendName");
Mono.fromCallable(backendService::doSomething)
.compose(RetryOperator.of(retry))
Updated over 5 years ago