INT-2024 polishing test, added timeout between send and receive
This commit is contained in:
@@ -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
|
||||
|
||||
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user