svn commit: r393024 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java

[rajdavies]

Author: rajdavies
Date: Mon Apr 10 12:09:55 2006
New Revision: 393024

URL: http://svn.apache.org/viewcvs?rev=393024&view=rev
Log:
some tuning of default buffer sizes etc.

Modified:
    
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java?rev=393024&r1=393023&r2=393024&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
 Mon Apr 10 12:09:55 2006
@@ -49,8 +49,8 @@
     private static final Log log = LogFactory.getLog(TcpTransport.class);
 
     private int connectionTimeout = 30000;
-    private int soTimeout = 10000;
-    private int socketBufferSize = 64 * 1024;
+    private int soTimeout = 0;
+    private int socketBufferSize = 128 * 1024;
     private Socket socket;
     private DataOutputStream dataOut;
     private DataInputStream dataIn;
@@ -309,9 +309,9 @@
     }
 
     protected void initializeStreams() throws IOException {
-        TcpBufferedInputStream buffIn = new 
TcpBufferedInputStream(socket.getInputStream(), 4096);
+        TcpBufferedInputStream buffIn = new 
TcpBufferedInputStream(socket.getInputStream(), 8*1024);
         this.dataIn = new DataInputStream(buffIn);
-        TcpBufferedOutputStream buffOut = new 
TcpBufferedOutputStream(socket.getOutputStream(), 8192);
+        TcpBufferedOutputStream buffOut = new 
TcpBufferedOutputStream(socket.getOutputStream(), 16*1024);
         this.dataOut = new DataOutputStream(buffOut);
     }