From 51f485847b0108aaa64b098bc2dab7c977965ac8 Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@vmware.com>
Date: Mon, 23 Aug 2010 19:15:26 +0000
Subject: [PATCH] INT-1367 Increase Pipe Size to 2048, Larger than a Normal
 MTU; avoids Blocking NIO Reader Thread in Many Cases

---
 .../integration/ip/tcp/connection/TcpNioConnection.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java
index 8e7a582142..c3a55e8821 100644
--- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java
+++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java
@@ -75,7 +75,7 @@ public class TcpNioConnection extends AbstractTcpConnection {
 	public TcpNioConnection(SocketChannel socketChannel, boolean server) throws Exception {
 		super(server);
 		this.socketChannel = socketChannel;
-		this.pipedInputStream = new PipedInputStream();
+		this.pipedInputStream = new PipedInputStream(2048);
 		this.pipedOutputStream = new PipedOutputStream(this.pipedInputStream);
 		this.channelOutputStream = new ChannelOutputStream();
 		getConnectionId();