diff options
author | Martin Ritchie <ritchiem@apache.org> | 2008-02-25 03:59:58 +0000 |
---|---|---|
committer | Martin Ritchie <ritchiem@apache.org> | 2008-02-25 03:59:58 +0000 |
commit | ba12699a5a6617ac8a1b117b18f73a8e0272fbe8 (patch) | |
tree | 7c365322b12ce1e9160eff24d52959e94d19bd61 | |
parent | 74091e2211758b399aaaccd057b0845d805f9fe6 (diff) | |
download | qpid-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.java | 5 |
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); } } |