Upgrade to Reactor 3.2 M3, Fix FluxMessageChannel
This commit is contained in:
@@ -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'
|
||||
|
||||
@@ -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();
|
||||
|
||||
Reference in New Issue
Block a user