diff --git a/spring-context/src/test/java/org/springframework/resilience/ReactiveRetryInterceptorTests.java b/spring-context/src/test/java/org/springframework/resilience/ReactiveRetryInterceptorTests.java index 22c0f5552e7..c9817841899 100644 --- a/spring-context/src/test/java/org/springframework/resilience/ReactiveRetryInterceptorTests.java +++ b/spring-context/src/test/java/org/springframework/resilience/ReactiveRetryInterceptorTests.java @@ -481,23 +481,23 @@ class ReactiveRetryInterceptorTests { }); } - @Retryable(timeout = 5, delay = 0) + @Retryable(timeout = 20, delay = 0) public Mono retryOperationWithTimeoutExceededAfterFirstRetry() { return Mono.fromCallable(() -> { counter.incrementAndGet(); if (counter.get() == 2) { - Thread.sleep(10); + Thread.sleep(50); } throw new IOException(counter.toString()); }); } - @Retryable(timeout = 5, delay = 0) + @Retryable(timeout = 20, delay = 0) public Mono retryOperationWithTimeoutExceededAfterSecondRetry() { return Mono.fromCallable(() -> { counter.incrementAndGet(); if (counter.get() == 3) { - Thread.sleep(10); + Thread.sleep(50); } throw new IOException(counter.toString()); }); diff --git a/spring-context/src/test/java/org/springframework/resilience/RetryInterceptorTests.java b/spring-context/src/test/java/org/springframework/resilience/RetryInterceptorTests.java index 8c6ae537e50..8da69719e1c 100644 --- a/spring-context/src/test/java/org/springframework/resilience/RetryInterceptorTests.java +++ b/spring-context/src/test/java/org/springframework/resilience/RetryInterceptorTests.java @@ -439,20 +439,20 @@ class RetryInterceptorTests { throw new IOException(Integer.toString(counter)); } - @Retryable(timeout = 5, delay = 0) + @Retryable(timeout = 20, delay = 0) public void retryOperationWithTimeoutExceededAfterFirstRetry() throws Exception { counter++; if (counter == 2) { - Thread.sleep(10); + Thread.sleep(50); } throw new IOException(Integer.toString(counter)); } - @Retryable(timeout = 5, delay = 0) + @Retryable(timeout = 20, delay = 0) public void retryOperationWithTimeoutExceededAfterSecondRetry() throws Exception { counter++; if (counter == 3) { - Thread.sleep(10); + Thread.sleep(50); } throw new IOException(Integer.toString(counter)); }