diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2009-08-12 18:23:04 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2009-08-12 18:23:04 +0000 |
| commit | 9ea7232b3b3301477da72fea8cc88942876e17c2 (patch) | |
| tree | 0b054afb361edd0c16c99bfad2a4a2ac791f07e6 | |
| parent | 372d1139c830d8d74fa64287853048d41fe0a818 (diff) | |
| download | qpid-python-9ea7232b3b3301477da72fea8cc88942876e17c2.tar.gz | |
Move closure logging to the end when things have been closed rather than before it is closed
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@803652 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java index dc12fdeff7..7bc4365152 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java +++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java @@ -657,10 +657,6 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, Managable { if (!_closed) { - _closed = true; - - CurrentActor.get().message(_logSubject, ConnectionMessages.CON_1002()); - if (_virtualHost != null) { _virtualHost.getConnectionRegistry().deregisterConnection(this); @@ -676,6 +672,10 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, Managable { task.doTask(this); } + + _closed = true; + + CurrentActor.get().message(_logSubject, ConnectionMessages.CON_1002()); } } |
