Add NOSONAR to IntReactiveUtils#emitNext() loop

This commit is contained in:
Artem Bilan
2020-08-11 09:53:20 -04:00
parent 3cb13af813
commit 217e43b194

View File

@@ -130,7 +130,7 @@ public final class IntegrationReactiveUtils {
@SuppressWarnings("unchecked")
MessageHandler messageHandler = (message) -> {
while (!sink.emitNext((Message<T>) message).hasEmitted()) {
LockSupport.parkNanos(10);
LockSupport.parkNanos(100); // NOSONAR
}
};
inputChannel.subscribe(messageHandler);