Merge pull request #1254 from fdesu/fix/reactor-netty-tcp-client-update

ChannelFutureMono renamed to FutureMono

Author: rstoyanchev

spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java

@@ -31,7 +31,7 @@
 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 ListenableFuture<Void> shutdown() {
 
 		this.stopping = true;
 
-		Mono<Void> completion = ChannelFutureMono.from(this.group.close())
+		Mono<Void> completion = FutureMono.from(this.group.close())
 				.doAfterTerminate((x, e) -> this.scheduler.shutdown());
 
 		return new MonoToListenableFutureAdapter<>(completion);