From e4ed1f6ffd899e41140f57ff33d3065d5951545e Mon Sep 17 00:00:00 2001 From: Sergei Ustimenko Date: Sat, 3 Dec 2016 18:56:42 +0100 Subject: [PATCH] ChannelFutureMono renamed to FutureMono In the latest reactor-netty there is renaming of ChannelFutureMono class to FutureMono. Thus build fails on the latest master. --- .../messaging/tcp/reactor/ReactorNettyTcpClient.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java index a53c02e045..15ca26fa05 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java @@ -31,7 +31,7 @@ import reactor.core.publisher.Mono; import reactor.core.publisher.MonoProcessor; import reactor.core.scheduler.Scheduler; import reactor.core.scheduler.Schedulers; -import reactor.ipc.netty.ChannelFutureMono; +import reactor.ipc.netty.FutureMono; import reactor.ipc.netty.NettyContext; import reactor.ipc.netty.NettyInbound; import reactor.ipc.netty.NettyOutbound; @@ -164,7 +164,7 @@ public class ReactorNettyTcpClient

implements TcpOperations

{ this.stopping = true; - Mono completion = ChannelFutureMono.from(this.group.close()) + Mono completion = FutureMono.from(this.group.close()) .doAfterTerminate((x, e) -> this.scheduler.shutdown()); return new MonoToListenableFutureAdapter<>(completion);