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

AMQP-232 Failing Tests (Timeout)

Browse Source 
Increase timeout to avoid intermittent test failures.
This commit is contained in:
Gary Russell
2012-05-22 07:35:48 -04:00
parent 3938b335c4
commit 23f66ed55d
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerRecoveryCachingConnectionIntegrationTests.java
View File

@@ -185,7 +185,10 @@ public class MessageListenerRecoveryCachingConnectionIntegrationTests {
CountDownLatch latch = new CountDownLatch(messageCount);
container = createContainer(queue.getName(), new AbortChannelListener(latch), createConnectionFactory());
Thread.sleep(500L);
int n = 0;
while (n++ < 100 && container.getActiveConsumerCount() != concurrentConsumers) {
Thread.sleep(50L);
}
assertEquals(concurrentConsumers, container.getActiveConsumerCount());
for (int i = 0; i < messageCount; i++) {
@@ -272,7 +275,7 @@ public class MessageListenerRecoveryCachingConnectionIntegrationTests {
}
private int getTimeout() {
return Math.min(1 + messageCount / (2 * concurrentConsumers), 30);
return Math.min(1 + messageCount / (concurrentConsumers), 30);
}
private SimpleMessageListenerContainer createContainer(String queueName, Object listener,