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 534855bb8d..65231cbc7e 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 @@ -93,8 +93,7 @@ public final class MessageChannelReactiveUtils { && (m = this.channel.receive()) != null) { // NOSONAR sink.next((Message) m); } - }), - FluxSink.OverflowStrategy.IGNORE) + })) .subscribeOn(Schedulers.elastic()) .subscribe(subscriber); }