Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert to errorStrategyContinue in FluxMessageChe

Browse Source 
https://build.spring.io/browse/INT-MASTER-1134

According the latest released reactor-core-3.2.0.M2, there is no yet
a `.onErrorContinue()` operator.
We need to stick with the `.errorStrategyContinue()` for time being
This commit is contained in:
Artem Bilan
2018-07-27 09:10:34 -04:00
parent 0c65bb741b
commit 8b13b2861d
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java
View File

@@ -82,7 +82,7 @@ public class FluxMessageChannel extends AbstractMessageChannel
ConnectableFlux<?> connectableFlux = ConnectableFlux<?> connectableFlux =
Flux.from(publisher) Flux.from(publisher)
.handle((message, sink) -> sink.next(send(message))) .handle((message, sink) -> sink.next(send(message)))
.onErrorContinue() .errorStrategyContinue()
.doOnComplete(() -> this.publishers.remove(publisher)) .doOnComplete(() -> this.publishers.remove(publisher))
.publish(); .publish();