Adapt to the latest Reactor

This commit is contained in:
Artem Bilan
2018-08-13 11:32:00 -04:00
parent a4ffddf226
commit e2b398ae10

View File

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