activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r393024 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
Date Mon, 10 Apr 2006 19:09:57 GMT
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);
     }
 



Mime
View raw message