Fix timing in the AsyncRabbitTemplateTests

spring-projects · Oct 4, 2024 · 82bed3f · 82bed3f
1 parent 949bf52
commit 82bed3f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/AsyncRabbitTemplateTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/AsyncRabbitTemplateTests.java
@@ -473,7 +473,8 @@ private Message checkMessageResult(CompletableFuture<Message> future, String exp
 		});
 		assertThat(cdl.await(10, TimeUnit.SECONDS)).isTrue();
 		assertThat(new String(resultRef.get().getBody())).isEqualTo(expected);
-		assertThat(TestUtils.getPropertyValue(future, "timeoutTask", Future.class).isCancelled()).isTrue();
+		await().untilAsserted(() ->
+				assertThat(TestUtils.getPropertyValue(future, "timeoutTask", Future.class).isCancelled()).isTrue());
 		return resultRef.get();
 	}