Add NOSONAR to IntReactiveUtils#emitNext() loop

artembilan · artembilan · commit 217e43b19440 · 2020-08-11T09:54:34.000-04:00
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
@@ -130,7 +130,7 @@ private static <T> Flux<Message<T>> adaptSubscribableChannelToPublisher(Subscrib
 			@SuppressWarnings("unchecked")
 			MessageHandler messageHandler = (message) -> {
 				while (!sink.emitNext((Message<T>) message).hasEmitted()) {
-					LockSupport.parkNanos(10);
+					LockSupport.parkNanos(100); // NOSONAR
 				}
 			};
 			inputChannel.subscribe(messageHandler);

Original file line number	Diff line number	Diff line change
`@@ -130,7 +130,7 @@ private static <T> Flux<Message<T>> adaptSubscribableChannelToPublisher(Subscrib`
`130`	`130`	`@SuppressWarnings("unchecked")`
`131`	`131`	`MessageHandler messageHandler = (message) -> {`
`132`	`132`	`while (!sink.emitNext((Message<T>) message).hasEmitted()) {`
`133`		`- LockSupport.parkNanos(10);`
	`133`	`+ LockSupport.parkNanos(100); // NOSONAR`
`134`	`134`	`}`
`135`	`135`	`};`
`136`	`136`	`inputChannel.subscribe(messageHandler);`