Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increase await() timeout to 30 sec for AsyncRabbitTemplateTests

Browse Source
This commit is contained in:
Artem Bilan
2024-10-22 11:50:32 -04:00
parent f150bf531a
commit c321e94890
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/AsyncRabbitTemplateTests.java
View File

@@ -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();