From fec5736675d6724ceee90bb17e028d7cc5570741 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 1 Aug 2011 09:42:09 -0400 Subject: [PATCH] INT-2024 polishing test, added timeout between send and receive --- .../redis/config/RedisInboundChannelAdapterParserTests.java | 5 ++--- .../redis/inbound/RedisInboundChannelAdapterTests.java | 1 + 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/config/RedisInboundChannelAdapterParserTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/config/RedisInboundChannelAdapterParserTests.java index 6b7d635a41..73e32e7193 100644 --- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/config/RedisInboundChannelAdapterParserTests.java +++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/config/RedisInboundChannelAdapterParserTests.java @@ -16,9 +16,6 @@ package org.springframework.integration.redis.config; -import static junit.framework.Assert.assertEquals; - -import org.junit.Ignore; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.DirectFieldAccessor; @@ -33,6 +30,8 @@ import org.springframework.integration.support.converter.SimpleMessageConverter; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; +import static junit.framework.Assert.assertEquals; + /** * @author Oleg Zhurakousky * @author Mark Fisher diff --git 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 index 22987ee689..870b5c4f20 100644 --- 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 @@ -57,6 +57,7 @@ public class RedisInboundChannelAdapterTests extends RedisAvailableTests{ redisTemplate.convertAndSend(redisChannelName, "test-" + i); } int counter = 0; + Thread.sleep(2000); for (int i = 0; i < numToTest; i++) { Message message = channel.receive(5000); assertNotNull(message);