Add slight delay to try and avoid integration test failures

This commit is contained in:
Dave Syer
2011-06-01 11:37:59 +01:00
parent c67ae69329
commit ee3338c9f7

View File

@@ -96,6 +96,8 @@ public class MessageListenerRecoveryCachingConnectionIntegrationTests {
boolean waited = latch.await(timeout, TimeUnit.SECONDS);
assertTrue("Timed out waiting for message", waited);
// Give message time to reach broker (intermittent test failures)!
Thread.sleep(500L);
// All messages committed
byte[] bytes = (byte[]) template.receiveAndConvert(sendQueue.getName());
assertNotNull(bytes);