From c44cd2b99bab9e8b8891b8ee910d675df4f1b020 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Fri, 27 Jul 2018 09:35:31 -0400
Subject: [PATCH] Upgrade to Reactor 3.2 M3, Fix FluxMessageChannel

---
 build.gradle                                                    | 2 +-
 .../springframework/integration/channel/FluxMessageChannel.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/build.gradle b/build.gradle
index 710ef43121..7c35aae550 100644
--- a/build.gradle
+++ b/build.gradle
@@ -126,7 +126,7 @@ subprojects { subproject ->
 		pahoMqttClientVersion = '1.2.0'
 		postgresVersion = '42.0.0'
 		reactorNettyVersion = '0.8.0.M1'
-		reactorVersion = '3.2.0.M2'
+		reactorVersion = '3.2.0.M3'
 		romeToolsVersion = '1.9.0'
 		servletApiVersion = '4.0.0'
 		smackVersion = '4.2.3'
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 9e9ad0b7b1..a87cb4c070 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,7 @@ public class FluxMessageChannel extends AbstractMessageChannel
 		ConnectableFlux<?> connectableFlux =
 				Flux.from(publisher)
 						.handle((message, sink) -> sink.next(send(message)))
-						.errorStrategyContinue()
+						.onErrorContinue()
 						.doOnComplete(() -> this.publishers.remove(publisher))
 						.hide() // TODO remove after upgrade to Reactor 3.1.9.RELEASE or later
 						.publish();