From 3ff9645167d8b847bfcf546a4d1f5cee378b8c31 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Tue, 24 Jul 2018 12:08:06 -0400
Subject: [PATCH] Fix `FluxMessageChannel` for the latest Reactor

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

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 84a8861913..7a96f8335c 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
@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2017 the original author or authors.
+ * Copyright 2002-2018 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -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))
 						.publish();