summaryrefslogtreecommitdiff
path: root/qpid/java/common/src
diff options
context:
space:
mode:
authorKeith Wall <kwall@apache.org>2014-10-14 16:13:20 +0000
committerKeith Wall <kwall@apache.org>2014-10-14 16:13:20 +0000
commit7fee0f39c4539c6348494ad902de348245b0b610 (patch)
treea96296ac6faf71e942ff7cfcd3640d43a99af317 /qpid/java/common/src
parenta830da546c31f11c6cc7646cb198b7d5d226a8c4 (diff)
downloadqpid-python-7fee0f39c4539c6348494ad902de348245b0b610.tar.gz
QPID-6152: [Java Client] Allow connection/session close time to be overridden by system property.
Change implementation so that the timeout is applied individually to each session close, the connection and the shutdown of the task pool. Also moved the shutdown of the task pool to a finally, so that it occurs even if one or more sessions fail to close. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1631810 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common/src')
-rw-r--r--qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java12
1 files changed, 12 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java b/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java
index b29e77f14d..86f5ddeeed 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java
@@ -134,6 +134,18 @@ public class ClientProperties
public static final int DEFAULT_SYNC_OPERATION_TIMEOUT = 60000;
/**
+ * System properties to change the default timeout used whilst closing connections
+ * and underlying sessions.
+ */
+ public static final String QPID_CLOSE_TIMEOUT = "qpid.close_timeout";
+
+ /**
+ * A default timeout value for close operations
+ */
+ public static final int DEFAULT_CLOSE_TIMEOUT = 2000;
+
+
+ /**
* System properties to change the default value used for TCP_NODELAY
*/
public static final String QPID_TCP_NODELAY_PROP_NAME = "qpid.tcp_nodelay";