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

Merge pull request #34 from garyrussell/AMQP-232

Browse Source 
* AMQP-232:
  AMQP-232 Wait for Shutdown
This commit is contained in:
Oleg Zhurakousky
2012-05-15 20:56:18 -04:00
parent ac71c3c4cb 092b89189b
commit cd3966710d
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerLifecycleIntegrationTests.java
View File

@@ -210,6 +210,10 @@ public class MessageListenerContainerLifecycleIntegrationTests {
container.shutdown();
}
int n = 0;
while (n++ < 100 && container.getActiveConsumerCount() > 0) {
Thread.sleep(100);
}
assertEquals(0, container.getActiveConsumerCount());
assertNull(template.receiveAndConvert(queue.getName()));