From 1fa165de3a45d25da2eec2e934953f9deee935e7 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Mon, 23 Aug 2010 19:44:25 +0000 Subject: [PATCH] INT-1367 Revert Increase Pipe Size to 2048 (Java 6 only) --- .../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 c3a55e8821..8e7a582142 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(2048); + this.pipedInputStream = new PipedInputStream(); this.pipedOutputStream = new PipedOutputStream(this.pipedInputStream); this.channelOutputStream = new ChannelOutputStream(); getConnectionId();