We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents b44578e + 089f8ec commit de207beCopy full SHA for de207be
src/test/java/com/rabbitmq/client/amqp/impl/TestUtils.java
@@ -70,6 +70,7 @@ static <T> T waitUntilStable(Supplier<T> call, Duration waitTime) {
70
T previousValue = call.get();
71
try {
72
Thread.sleep(waitTime.toMillis());
73
+ waitedTime = waitedTime.plus(waitTime);
74
} catch (InterruptedException e) {
75
Thread.currentThread().interrupt();
76
throw new RuntimeException(e);
0 commit comments