From ee3338c9f780bd9155e2c25bd59d7107fd3b1d4b Mon Sep 17 00:00:00 2001
From: Dave Syer <dsyer@vmware.com>
Date: Wed, 1 Jun 2011 11:37:59 +0100
Subject: [PATCH] Add slight delay to try and avoid integration test failures

---
 ...essageListenerRecoveryCachingConnectionIntegrationTests.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerRecoveryCachingConnectionIntegrationTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerRecoveryCachingConnectionIntegrationTests.java
index 33e51084..bc2c9ec3 100644
--- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerRecoveryCachingConnectionIntegrationTests.java
+++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerRecoveryCachingConnectionIntegrationTests.java
@@ -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);