Код: Выделить всё
public ResponseEntity getByTokenResource(HttpHeaders headers, String payload) {
return invoke(headers, payload);
}
.......
@TimeLimiter(name = "getToken")
@CircuitBreaker(name = "getToken", fallbackMethod = "fallbackRequestException")
public ResponseEntity getByTokenPayload(HttpHeaders headers, String payload)
{
return service.getByTokenResource(headers, payload);
}
.......
Details getRequest(HttpHeaders httpHeaders, String url) {
try {
ResponseEntity response =
secondService.getByToken(httpHeaders, url);
} catch (Exception e) {
......
}
return ....;
}
Код: Выделить всё
@Bulkhead(name = "getToken", type = Bulkhead.Type.THREADPOOL)
@TimeLimiter(name = "getToken")
@CircuitBreaker(name = "getToken", fallbackMethod = "fallbackRequestException")
public ResponseEntity getByTokenPayload(HttpHeaders headers, String url) {
return CompletableFuture.supplyAsync(() -> {
ResponseEntity result = service.getByTokenResource(headers, url);
}).thenApply(result -> {
return result;
});
}
Вы знаете, как я могу решить эту проблему?
Подробнее здесь: https://stackoverflow.com/questions/790 ... ync-lambda