diff options
| author | Robert Gemmell <robbie@apache.org> | 2013-03-27 23:28:27 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2013-03-27 23:28:27 +0000 |
| commit | 7799aa578726bd78bc71a4c94d0c4ea9f83f9fa5 (patch) | |
| tree | f6d3bf3b72fcde4e9d944145c47412f99c519cdb /qpid/java | |
| parent | 41e967fa0309eca6743dd777436bbc130e7437c0 (diff) | |
| download | qpid-python-7799aa578726bd78bc71a4c94d0c4ea9f83f9fa5.tar.gz | |
QPID-4666: fix exception messages during during 0-10 MessageSubscribe failures: include the queue name in exception message sent following ACL refusal, and fix typo in exception sent when an subscription already exists with the given destination.
Based on patch by JAkub Scholz with some updates of my own.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1461895 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java index d83bd1c4dc..7a6c0c42be 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/transport/ServerSessionDelegate.java @@ -192,7 +192,7 @@ public class ServerSessionDelegate extends SessionDelegate if(((ServerSession)session).getSubscription(destination)!=null) { - exception(session, method, ExecutionErrorCode.NOT_ALLOWED, "Subscription already exists with destaination: '"+destination+"'"); + exception(session, method, ExecutionErrorCode.NOT_ALLOWED, "Subscription already exists with destination '"+destination+"'"); } else { @@ -275,7 +275,7 @@ public class ServerSessionDelegate extends SessionDelegate } catch (AMQException e) { - exception(session, method, e, "Cannot subscribe to '" + destination); + exception(session, method, e, "Cannot subscribe to queue '" + queueName + "' with destination '" + destination); } } } |
