Increase consume timeout for Redis Streams test

artembilan · artembilan · commit d020d7abfb85 · 2020-10-08T11:45:56.000-04:00
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
@@ -209,7 +209,7 @@ public void testReadingPendingMessageWithNoAutoACK() {
 
 		this.messageHandler.handleMessage(new GenericMessage<>(person));
 
-		stepVerifier.verify(Duration.ofSeconds(10));
+		stepVerifier.verify(Duration.ofSeconds(20));
 
 		await().until(() ->
 				template.opsForStream()
