Functional Web Spring 5 with Resilience4j

DemoApplication.java

@SpringBootApplication
@Configuration
public class DemoApplication {

	private CircuitBreakerRegistry circuitBreakerRegistry;
	private RetryRegistry retryRegistry;
	private EmployeeRepository employeeRepository;

	public DemoApplication(CircuitBreakerRegistry circuitBreakerRegistry,
						   RetryRegistry retryRegistry,
						   EmployeeRepository employeeRepository){

		this.circuitBreakerRegistry = circuitBreakerRegistry;
		this.retryRegistry = retryRegistry;
		this.employeeRepository = employeeRepository;
	}

	@Bean
	RouterFunction<ServerResponse> getAllEmployeesRoute() {
		return route(GET("/employees"),
				req -> ok().body(protect(employeeRepository.findAllEmployees()), Employee.class));
	}

	private <T> Flux<T> protect(Flux<T> flux){
		CircuitBreaker circuitBreaker = circuitBreakerRegistry.circuitBreaker("employeeBackend");
		Retry retry = retryRegistry.retry("employeeBackend");
		return flux
				.transform(CircuitBreakerOperator.of(circuitBreaker))
				.transform(RetryOperator.of(retry));
	}


	public static void main(String[] args) {
		SpringApplication.run(DemoApplication.class, args);
	}

}