SpringResillencerjDemoApplication.kt

@RestController
class SomeController {
    @Autowired
    private lateinit var someService: SomeService
    @Autowired
    private lateinit var reactiveCircuitBreakerFactory: ReactiveCircuitBreakerFactory<*, *>

    @GetMapping("/process", produces = [MediaType.TEXT_EVENT_STREAM_VALUE])
    fun somRequest(@RequestParam id: Int): Mono<String> {
        return reactiveCircuitBreakerFactory
                .create("someService")
                .run(someService.process(id), Function {
                    Mono.just("just recovered from error! => ${it.localizedMessage}")
                })

    }
}