From ba974320434a623d466ed39bb860dca7b368aae3 Mon Sep 17 00:00:00 2001
From: Stephane Maldini <smaldini@pivotal.io>
Date: Tue, 21 Feb 2017 16:00:19 +0000
Subject: [PATCH] prepare for reactor-netty 0.6.1.RELEASE

---
 .../messaging/tcp/reactor/ReactorNettyTcpClient.java            | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 ab8ba2ed39..529fc23a37 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
@@ -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)