summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2009-08-12 18:23:04 +0000
committerMartin Ritchie <ritchiem@apache.org>2009-08-12 18:23:04 +0000
commit9ea7232b3b3301477da72fea8cc88942876e17c2 (patch)
tree0b054afb361edd0c16c99bfad2a4a2ac791f07e6
parent372d1139c830d8d74fa64287853048d41fe0a818 (diff)
downloadqpid-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.java8
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());
}
}