From 095cc2283eb347fc11ee44b5135d17c395731104 Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@pivotal.io>
Date: Thu, 13 Jul 2017 22:06:33 +0200
Subject: [PATCH] Replace constant from QueueSupplier with local one

---
 .../messaging/tcp/reactor/ReactorNettyTcpClient.java        | 6 ++++--
 1 file changed, 4 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 da496eed34..d788428e83 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
@@ -48,7 +48,6 @@ import reactor.ipc.netty.resources.LoopResources;
 import reactor.ipc.netty.resources.PoolResources;
 import reactor.ipc.netty.tcp.TcpClient;
 import reactor.ipc.netty.tcp.TcpResources;
-import reactor.util.concurrent.QueueSupplier;
 
 import org.springframework.messaging.Message;
 import org.springframework.messaging.tcp.ReconnectStrategy;
@@ -69,6 +68,9 @@ import org.springframework.util.concurrent.SettableListenableFuture;
  */
 public class ReactorNettyTcpClient<P> implements TcpOperations<P> {
 
+	private static final int PUBLISH_ON_BUFFER_SIZE = 16;
+
+
 	private final TcpClient tcpClient;
 
 	private final ReactorNettyCodec<P> codec;
@@ -246,7 +248,7 @@ public class ReactorNettyTcpClient<P> implements TcpOperations<P> {
 
 			inbound.receiveObject()
 					.cast(Message.class)
-					.publishOn(scheduler, QueueSupplier.SMALL_BUFFER_SIZE)
+					.publishOn(scheduler, PUBLISH_ON_BUFFER_SIZE)
 					.subscribe(
 							connectionHandler::handleMessage,
 							connectionHandler::handleFailure,