DemoApplication.java

@SpringBootApplication
@Configuration
public class DemoApplication {

  private EmployeeRepository employeeRepository;
	private CircuitBreaker circuitBreaker;
	private Retry retry;

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

        this.employeeRepository = employeeRepository;
		    this.circuitBreaker = circuitBreakerRegistry.circuitBreaker("employeeBackend");
        this.retry = retryRegistry.retry("employeeBackend");
	}

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

	private <T> Flux<T> protect(Flux<T> flux){
		return flux
				.compose(CircuitBreakerOperator.of(circuitBreaker))
				.compose(RetryOperator.of(retry));
	}


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

}