diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2007-04-04 10:42:59 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2007-04-04 10:42:59 +0000 |
| commit | 67d2bdda471640a68e12d63f5de471471057a193 (patch) | |
| tree | 69597b82361398a92f8dad43e679db922afa5dfe /java/client/src | |
| parent | 3e425e988e155ec8f08a90f59fda105be15a6da6 (diff) | |
| download | qpid-python-67d2bdda471640a68e12d63f5de471471057a193.tar.gz | |
Added default timeout to AMQConnection.close();
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@525487 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java index 413524b6d8..2274f2964f 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java @@ -149,6 +149,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect /** Thread Pool for executing connection level processes. Such as returning bounced messages. */ private final ExecutorService _taskPool = Executors.newCachedThreadPool(); + private static final long DEFAULT_TIMEOUT = 1000 * 30; /** * @param broker brokerdetails @@ -732,7 +733,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect public void close() throws JMSException { - close(-1); + close(DEFAULT_TIMEOUT); } public void close(long timeout) throws JMSException |