Author: rajdavies
Date: Thu Aug 14 01:30:32 2008
New Revision: 685808
URL: http://svn.apache.org/viewvc?rev=685808&view=rev
Log:
Applied patch for https://issues.apache.org/activemq/browse/AMQ-1860
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java?rev=685808&r1=685807&r2=685808&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java
Thu Aug 14 01:30:32 2008
@@ -74,6 +74,11 @@
* This parameter is most probably set in Connection or TransportConnector
URIs.
*/
protected boolean trace = false;
+
+ protected int soTimeout = 0;
+ protected int socketBufferSize = 64 * 1024;
+ protected int connectionTimeout = 30000;
+
/**
* Name of the LogWriter implementation to use.
* Names are mapped to classes in the
resources/META-INF/services/org/apache/activemq/transport/logwriters directory.
@@ -363,6 +368,9 @@
options.put("minmumWireFormatVersion", Integer
.valueOf(minmumWireFormatVersion));
options.put("trace", Boolean.valueOf(trace));
+ options.put("soTimeout", Integer.valueOf(soTimeout));
+ options.put("soTimeout", Integer.valueOf(soTimeout));
+ options.put("connectionTimeout",
Integer.valueOf(socketBufferSize));
options.put("logWriterName", logWriterName);
options
.put("dynamicManagement", Boolean
@@ -386,4 +394,28 @@
}
}
}
+
+ public int getSoTimeout() {
+ return soTimeout;
+ }
+
+ public void setSoTimeout(int soTimeout) {
+ this.soTimeout = soTimeout;
+ }
+
+ public int getSocketBufferSize() {
+ return socketBufferSize;
+ }
+
+ public void setSocketBufferSize(int socketBufferSize) {
+ this.socketBufferSize = socketBufferSize;
+ }
+
+ public int getConnectionTimeout() {
+ return connectionTimeout;
+ }
+
+ public void setConnectionTimeout(int connectionTimeout) {
+ this.connectionTimeout = connectionTimeout;
+ }
}
\ No newline at end of file
