From d020d7abfb8539e7d3102ee077c1590fd035ef05 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 8 Oct 2020 11:45:56 -0400 Subject: [PATCH] Increase consume timeout for Redis Streams test --- .../redis/inbound/ReactiveRedisStreamMessageProducerTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java index 2c5b8c6a2c..d9df4f975b 100644 --- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java +++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java @@ -209,7 +209,7 @@ public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests this.messageHandler.handleMessage(new GenericMessage<>(person)); - stepVerifier.verify(Duration.ofSeconds(10)); + stepVerifier.verify(Duration.ofSeconds(20)); await().until(() -> template.opsForStream()