From e2b398ae10e19747fa41a4e1b60d32d75885c8be Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Mon, 13 Aug 2018 11:32:00 -0400
Subject: [PATCH] Adapt to the latest Reactor

---
 .../integration/channel/FluxMessageChannel.java                | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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();