diff --git a/spring-integration-core/src/main/java/org/springframework/integration/util/IntegrationReactiveUtils.java b/spring-integration-core/src/main/java/org/springframework/integration/util/IntegrationReactiveUtils.java index dfb2bac5a4..7ef90c7001 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/util/IntegrationReactiveUtils.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/util/IntegrationReactiveUtils.java @@ -130,7 +130,7 @@ public final class IntegrationReactiveUtils { @SuppressWarnings("unchecked") MessageHandler messageHandler = (message) -> { while (!sink.emitNext((Message) message).hasEmitted()) { - LockSupport.parkNanos(10); + LockSupport.parkNanos(100); // NOSONAR } }; inputChannel.subscribe(messageHandler);