提交 2802926c 编写于 作者: S Stephane Maldini

update STOMP support to reactor-netty 0.6

上级 70bab236
......@@ -61,11 +61,11 @@ public class ReactorNettyTcpConnection<P> implements TcpConnection<P> {
@Override
public ListenableFuture<Void> send(Message<P> message) {
ByteBuf byteBuf = this.inbound.alloc()
.buffer();
ByteBuf byteBuf = this.outbound.alloc()
.buffer();
this.encoder.accept(byteBuf, message);
return new MonoToListenableFutureAdapter<>(this.outbound.send(Mono.just(byteBuf)
.then()));
return new MonoToListenableFutureAdapter<>(this.outbound.send(Mono.just(byteBuf))
.then());
}
@Override
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册