From c321e948903f42bcaa3e8c1a78471fb71a4bf853 Mon Sep 17 00:00:00 2001
From: Artem Bilan <artem.bilan@broadcom.com>
Date: Tue, 22 Oct 2024 11:50:32 -0400
Subject: [PATCH] Increase `await()` timeout to 30 sec for
 `AsyncRabbitTemplateTests`

---
 .../amqp/rabbit/AsyncRabbitTemplateTests.java             | 8 ++++++++
 1 file changed, 8 insertions(+)

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
index e054a7ab..b0cb6d92 100644
--- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/AsyncRabbitTemplateTests.java
+++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/AsyncRabbitTemplateTests.java
@@ -22,6 +22,7 @@ import static org.assertj.core.api.Assertions.fail;
 import static org.awaitility.Awaitility.await;
 import static org.mockito.Mockito.mock;
 
+import java.time.Duration;
 import java.util.Map;
 import java.util.UUID;
 import java.util.concurrent.CancellationException;
@@ -35,6 +36,8 @@ import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.BiConsumer;
 
+import org.awaitility.Awaitility;
+import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 
 import org.springframework.amqp.core.Address;
@@ -91,6 +94,11 @@ public class AsyncRabbitTemplateTests {
 
 	private final Message fooMessage = new SimpleMessageConverter().toMessage("foo", new MessageProperties());
 
+	@BeforeAll
+	static void setup() {
+		Awaitility.setDefaultTimeout(Duration.ofSeconds(30));
+	}
+
 	@Test
 	public void testConvert1Arg() throws Exception {
 		final AtomicBoolean mppCalled = new AtomicBoolean();