From 217e43b19440b524d350f713daf46bf819b3a2d7 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 11 Aug 2020 09:53:20 -0400 Subject: [PATCH] Add NOSONAR to IntReactiveUtils#emitNext() loop --- .../integration/util/IntegrationReactiveUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);