Increase wait timeout in FluxMessageChannelTests

Author: artembilan

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 @@ void testFluxMessageChannelCleanUp() throws InterruptedException {
 		flowRegistration.destroy();
 
 		await()
+				.atMost(Duration.ofSeconds(30))
 				.until(() -> TestUtils.getPropertyValue(flux, "sink.sink.done", Boolean.class));
 	}
 
@@ -184,7 +186,7 @@ public String handle(int payload) {
 			if (payload == 5) {
 				throw new IllegalStateException("intentional");
 			}
-			return "" + payload;
+			return String.valueOf(payload);
 		}
 
 		@Bean