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 | c3792b6920ceb464e5d1c098931fe63ac64f5645 (patch) | |
| tree | aa5d9a1c50d71de460d95af576af5b53f99fd8a5 /qpid | |
| parent | 97bcb39a728140aa34edcf20722289c8f9f8f754 (diff) | |
| download | qpid-python-c3792b6920ceb464e5d1c098931fe63ac64f5645.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@803652 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java index dc12fdeff7..7bc4365152 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java +++ b/qpid/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()); } } |
