polishing broken test trying to determine why it fails in CI

2011-08-02 08:10:27 -04:00
parent c6403f3feb
commit 563d1db0f1
2 changed files with 5 additions and 1 deletions
--- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/RedisInboundChannelAdapterTests.java
+++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/RedisInboundChannelAdapterTests.java
@@ -60,6 +60,9 @@ public class RedisInboundChannelAdapterTests extends RedisAvailableTests{
 		Thread.sleep(2000);
 		for (int i = 0; i < numToTest; i++) {
 			Message<?> message = channel.receive(5000);
+			if (message == null){
+				throw new RuntimeException("Failed to receive message # " + i);
+			}
 			assertNotNull(message);
 			assertTrue(message.getPayload().toString().startsWith("test-"));
 			counter++;