From 8c4675aa832744afb7825e581c1b1215e3551ec7 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 13 Feb 2020 14:11:21 -0500 Subject: [PATCH] Fix new Sonar smell * Make `adaptPollableChannelToPublisher()` as non-blocking --- .../integration/channel/MessageChannelReactiveUtils.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/MessageChannelReactiveUtils.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/MessageChannelReactiveUtils.java index 15f98671a0..2b11d1e090 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/channel/MessageChannelReactiveUtils.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/channel/MessageChannelReactiveUtils.java @@ -73,9 +73,9 @@ public final class MessageChannelReactiveUtils { @SuppressWarnings("unchecked") private static Publisher> adaptPollableChannelToPublisher(PollableChannel inputChannel) { - return Mono.fromCallable(() -> (Message) inputChannel.receive()) + return Mono.fromCallable(() -> (Message) inputChannel.receive(0)) .subscribeOn(Schedulers.boundedElastic()) - .repeatWhenEmpty(it -> it.delayElements(Duration.ofMillis(10))) + .repeatWhenEmpty(it -> it.delayElements(Duration.ofMillis(100))) // NOSONAR - magic .repeat(); }