Wait a little bit longer.
This commit is contained in:
@@ -46,7 +46,7 @@ public class RedisMessageListenerIntegrationTest {
|
|||||||
public void testOnMessage() throws Exception {
|
public void testOnMessage() throws Exception {
|
||||||
String message = "Message " + UUID.randomUUID();
|
String message = "Message " + UUID.randomUUID();
|
||||||
redisMessagePublisher.publish(message);
|
redisMessagePublisher.publish(message);
|
||||||
Thread.sleep(100);
|
Thread.sleep(1000);
|
||||||
assertTrue(RedisMessageSubscriber.messageList.get(0).contains(message));
|
assertTrue(RedisMessageSubscriber.messageList.get(0).contains(message));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user