diff --git a/spring-cloud-circuitbreaker-resilience4j/src/main/java/org/springframework/cloud/circuitbreaker/resilience4j/ReactiveResilience4JCircuitBreaker.java b/spring-cloud-circuitbreaker-resilience4j/src/main/java/org/springframework/cloud/circuitbreaker/resilience4j/ReactiveResilience4JCircuitBreaker.java index 504227e..30fcd5e 100644 --- a/spring-cloud-circuitbreaker-resilience4j/src/main/java/org/springframework/cloud/circuitbreaker/resilience4j/ReactiveResilience4JCircuitBreaker.java +++ b/spring-cloud-circuitbreaker-resilience4j/src/main/java/org/springframework/cloud/circuitbreaker/resilience4j/ReactiveResilience4JCircuitBreaker.java @@ -67,7 +67,7 @@ public class ReactiveResilience4JCircuitBreaker implements ReactiveCircuitBreake config.getTimeLimiterConfig().getTimeoutDuration().toMillis(), t)); if (fallback != null) { - toReturn = toReturn.onErrorResume(t -> fallback.apply(t)); + toReturn = toReturn.onErrorResume(fallback); } return toReturn; } @@ -86,7 +86,7 @@ public class ReactiveResilience4JCircuitBreaker implements ReactiveCircuitBreake config.getTimeLimiterConfig().getTimeoutDuration().toMillis(), t)); if (fallback != null) { - toReturn = toReturn.onErrorResume(t -> fallback.apply(t)); + toReturn = toReturn.onErrorResume(fallback); } return toReturn; }