summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2008-02-25 03:59:58 +0000
committerMartin Ritchie <ritchiem@apache.org>2008-02-25 03:59:58 +0000
commitba12699a5a6617ac8a1b117b18f73a8e0272fbe8 (patch)
tree7c365322b12ce1e9160eff24d52959e94d19bd61
parent74091e2211758b399aaaccd057b0845d805f9fe6 (diff)
downloadqpid-python-ba12699a5a6617ac8a1b117b18f73a8e0272fbe8.tar.gz
QPID-809 : Added comments and improved logging msgs.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@630730 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/handler/ConnectionCloseMethodHandler.java5
1 files changed, 4 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionCloseMethodHandler.java b/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionCloseMethodHandler.java
index bd16211880..fdcb493f38 100644
--- a/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionCloseMethodHandler.java
+++ b/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionCloseMethodHandler.java
@@ -75,8 +75,9 @@ public class ConnectionCloseMethodHandler implements StateAwareMethodListener<Co
{
if (errorCode == AMQConstant.NOT_ALLOWED || (errorCode == AMQConstant.ACCESS_REFUSED))
{
- _logger.info("Authentication Error:" + Thread.currentThread().getName());
+ _logger.info("Error :" + errorCode +":"+ Thread.currentThread().getName());
+ // todo ritchiem : Why do this here when it is going to be done in the finally block?
session.closeProtocolSession();
// todo this is a bit of a fudge (could be conssidered such as each new connection needs a new state manager or at least a fresh state.
@@ -98,6 +99,8 @@ public class ConnectionCloseMethodHandler implements StateAwareMethodListener<Co
session.closeProtocolSession();
+ // ritchiem: Doing this though will cause any waiting connection start to be released without being able to
+ // see what the cause was.
stateManager.changeState(AMQState.CONNECTION_CLOSED);
}
}