diff --git a/src/main/java/org/springframework/retry/policy/CircuitBreakerRetryPolicy.java b/src/main/java/org/springframework/retry/policy/CircuitBreakerRetryPolicy.java index 45aa756..e0ea207 100644 --- a/src/main/java/org/springframework/retry/policy/CircuitBreakerRetryPolicy.java +++ b/src/main/java/org/springframework/retry/policy/CircuitBreakerRetryPolicy.java @@ -118,7 +118,7 @@ public class CircuitBreakerRetryPolicy implements RetryPolicy { resetTimeout = this.resetTimeoutSupplier.get(); } long openTimeout = this.openTimeout; - if (this.resetTimeoutSupplier != null) { + if (this.openTimeoutSupplier != null) { openTimeout = this.openTimeoutSupplier.get(); } return new CircuitBreakerRetryContext(parent, this.delegate, resetTimeout, openTimeout);