diff options
| author | Aidan Skinner <aidan@apache.org> | 2008-04-21 11:33:07 +0000 |
|---|---|---|
| committer | Aidan Skinner <aidan@apache.org> | 2008-04-21 11:33:07 +0000 |
| commit | 2a674925d542ad65ddbb931461afc4f902e6898a (patch) | |
| tree | 008f3bdb7ac59eb0b41c1a18520181de7ef6af5d | |
| parent | d28f0eca5aed6d5cb2a36fe3f22b4bd13b133763 (diff) | |
| download | qpid-python-2a674925d542ad65ddbb931461afc4f902e6898a.tar.gz | |
QPID-832 revert last commit, 650099
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/thegreatmerge@650108 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java index 5a05325948..69ddf7b08f 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java @@ -913,31 +913,31 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect { synchronized(_sessionCreationLock) { - synchronized (getFailoverMutex()) + if(!sessions.isEmpty()) + { + AMQSession session = sessions.remove(0); + synchronized(session.getMessageDeliveryLock()) + { + close(sessions, timeout); + } + } + else { if (!_closed.getAndSet(true)) { - if(!sessions.isEmpty()) - { - AMQSession session = sessions.remove(0); - synchronized(session.getMessageDeliveryLock()) - { - close(sessions, timeout); - } - } - else + synchronized (getFailoverMutex()) { try { long startCloseTime = System.currentTimeMillis(); - closeAllSessions(null, timeout, startCloseTime); + closeAllSessions(null, timeout, startCloseTime); - //This MUST occur after we have successfully closed all Channels/Sessions - _taskPool.shutdown(); + //This MUST occur after we have successfully closed all Channels/Sessions + _taskPool.shutdown(); - if (!_taskPool.isTerminated()) - { + if (!_taskPool.isTerminated()) + { try { // adjust timeout |