diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java index a87cb4c070..8f3386ebf5 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java @@ -82,7 +82,8 @@ public class FluxMessageChannel extends AbstractMessageChannel ConnectableFlux connectableFlux = Flux.from(publisher) .handle((message, sink) -> sink.next(send(message))) - .onErrorContinue() + .onErrorContinue((throwable, o) -> logger.warn("Error during processing event: " + o, throwable) + ) .doOnComplete(() -> this.publishers.remove(publisher)) .hide() // TODO remove after upgrade to Reactor 3.1.9.RELEASE or later .publish();