You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2019/07/26 09:25:56 UTC
[activemq] branch master updated: AMQ-6949: SocketTimeoutException
when using HTTP transport connector
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/master by this push:
new ea0bcc1 AMQ-6949: SocketTimeoutException when using HTTP transport connector
new 32ddadc Merge pull request #362 from suem/master
ea0bcc1 is described below
commit ea0bcc12f77594228bb270f199ba54b5dc3ce453
Author: suem <su...@users.noreply.github.com>
AuthorDate: Wed May 29 15:28:30 2019 +0200
AMQ-6949: SocketTimeoutException when using HTTP transport connector
A default socket timeout of 30 secods for the HTTP client was introduced with the following ticket: https://issues.apache.org/jira/browse/AMQ-6397
This timeout somewhow seems to conflict with the keep alive requests that stays open for arround 30 seconds. I increased the default timeout to 90 seconds and this seems to resolve the problem.
---
.../java/org/apache/activemq/transport/http/HttpClientTransport.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/activemq-http/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java b/activemq-http/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java
index 2480daa..8e13fff 100644
--- a/activemq-http/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java
+++ b/activemq-http/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java
@@ -72,7 +72,7 @@ import org.slf4j.LoggerFactory;
*/
public class HttpClientTransport extends HttpTransportSupport {
- public static final int MAX_CLIENT_TIMEOUT = 30000;
+ public static final int MAX_CLIENT_TIMEOUT = 90000;
private static final Logger LOG = LoggerFactory.getLogger(HttpClientTransport.class);
private static final IdGenerator CLIENT_ID_GENERATOR = new IdGenerator();