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);