diff options
author | Robert Gemmell <robbie@apache.org> | 2011-09-13 00:26:40 +0000 |
---|---|---|
committer | Robert Gemmell <robbie@apache.org> | 2011-09-13 00:26:40 +0000 |
commit | a0cf50b7888c155260d295d72cff95dbc3965357 (patch) | |
tree | b9421cd313d59d33c0092926ee98fb48dc0c5e40 /java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | |
parent | dd6407e053b8fb26f242f4a41d90798ee269f991 (diff) | |
download | qpid-python-a0cf50b7888c155260d295d72cff95dbc3965357.tar.gz |
QPID-3428: make the Java broker validate 0-10 Session names, enabling it to satisfy the clients new ClientID verification feature. Misc updates to the clients verification process.
Applied patch from Andrew MacBean
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1169982 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/main/java/org/apache/qpid/client/AMQConnection.java')
-rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java index d9194a3408..f15af72407 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java @@ -1451,11 +1451,14 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect { try { - _delegate.verifyClientID(); + if (!_delegate.verifyClientID()) + { + throw new AMQException(AMQConstant.ALREADY_EXISTS,"ClientID must be unique"); + } } catch(JMSException e) { - throw new AMQException(AMQConstant.ALREADY_EXISTS,"ClientID must be unique",e); + throw new AMQException(e.getMessage(),e); } } } |