GH-1296: Fix Race in Test

garyrussell · garyrussell · commit 7dc129af9a97 · 2021-01-13T10:53:50.000-05:00
diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/DirectMessageListenerContainerIntegrationTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/DirectMessageListenerContainerIntegrationTests.java
@@ -701,6 +701,8 @@ else if (event instanceof AsyncConsumerStartedEvent) {
 				latch.countDown();
 			}
 		});
+		container.setMonitorInterval(500);
+		container.setFailedDeclarationRetryInterval(500);
 		container.afterPropertiesSet();
 		container.start();
 		assertTrue(latch.await(10, TimeUnit.SECONDS));

Original file line number	Diff line number	Diff line change
`@@ -701,6 +701,8 @@ else if (event instanceof AsyncConsumerStartedEvent) {`
`701`	`701`	`latch.countDown();`
`702`	`702`	`}`
`703`	`703`	`});`
	`704`	`+ container.setMonitorInterval(500);`
	`705`	`+ container.setFailedDeclarationRetryInterval(500);`
`704`	`706`	`container.afterPropertiesSet();`
`705`	`707`	`container.start();`
`706`	`708`	`assertTrue(latch.await(10, TimeUnit.SECONDS));`