GH-1296: Fix Race in Test

garyrussell · garyrussell · commit c8e052177530 · 2021-01-13T10:26: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
@@ -699,6 +699,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
`@@ -699,6 +699,8 @@ else if (event instanceof AsyncConsumerStartedEvent) {`
`699`	`699`	`latch.countDown();`
`700`	`700`	`}`
`701`	`701`	`});`
	`702`	`+ container.setMonitorInterval(500);`
	`703`	`+ container.setFailedDeclarationRetryInterval(500);`
`702`	`704`	`container.afterPropertiesSet();`
`703`	`705`	`container.start();`
`704`	`706`	`assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue();`