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 7a96f8335c..5106c8b784 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)))
-						.onErrorContinue()
+						.errorStrategyContinue()
 						.doOnComplete(() -> this.publishers.remove(publisher))
 						.publish();