GH-1296: Fix Race in Test

garyrussell · garyrussell · commit e9da112f96b1 · 2021-01-13T10:53:21.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
@@ -711,6 +711,8 @@ else if (event instanceof AsyncConsumerStartedEvent) {
 				latch.countDown();
 			}
 		});
+		container.setMonitorInterval(500);
+		container.setFailedDeclarationRetryInterval(500);
 		container.afterPropertiesSet();
 		container.start();
 		assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue();

Original file line number	Diff line number	Diff line change
`@@ -711,6 +711,8 @@ else if (event instanceof AsyncConsumerStartedEvent) {`
`711`	`711`	`latch.countDown();`
`712`	`712`	`}`
`713`	`713`	`});`
	`714`	`+ container.setMonitorInterval(500);`
	`715`	`+ container.setFailedDeclarationRetryInterval(500);`
`714`	`716`	`container.afterPropertiesSet();`
`715`	`717`	`container.start();`
`716`	`718`	`assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue();`