root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions 8 Packages Projects Releases Wiki Activity

prepare for reactor-netty 0.6.1.RELEASE

This commit is contained in:
Stephane Maldini 2017-02-21 16:00:19 +00:00
parent 6242e30539
commit ba97432043
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -240,7 +240,7 @@ public class ReactorNettyTcpClient<P> implements TcpOperations<P> {
TcpConnection<P> connection = new ReactorNettyTcpConnection<>(inbound, outbound, codec, completion);
scheduler.schedule(() -> connectionHandler.afterConnected(connection));
inbound.context().addDecoder(new StompMessageDecoder<>(codec));
inbound.context().addHandler(new StompMessageDecoder<>(codec));
inbound.receiveObject()
.cast(Message.class)