From 229e3cc08132e3d53d48da8387394a64a880f7cf Mon Sep 17 00:00:00 2001
From: abilan <abilan@vmware.com>
Date: Wed, 28 Jun 2023 13:21:41 -0400
Subject: [PATCH] Increase wait timeout in FluxMessageChannelTests

---
 .../integration/channel/reactive/FluxMessageChannelTests.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/FluxMessageChannelTests.java b/spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/FluxMessageChannelTests.java
index 40fb4d3aa7..0ca1165f0f 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/FluxMessageChannelTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/FluxMessageChannelTests.java
@@ -16,6 +16,7 @@
 
 package org.springframework.integration.channel.reactive;
 
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
@@ -143,6 +144,7 @@ public class FluxMessageChannelTests {
 		flowRegistration.destroy();
 
 		await()
+				.atMost(Duration.ofSeconds(30))
 				.until(() -> TestUtils.getPropertyValue(flux, "sink.sink.done", Boolean.class));
 	}
 
@@ -184,7 +186,7 @@ public class FluxMessageChannelTests {
 			if (payload == 5) {
 				throw new IllegalStateException("intentional");
 			}
-			return "" + payload;
+			return String.valueOf(payload);
 		}
 
 		@Bean