diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2013-02-28 21:37:52 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2013-02-28 21:37:52 +0000 |
| commit | f2e1382c67f6acd9840d449e6de9a146cfef6f92 (patch) | |
| tree | 5e4dbd4729ffbe876e0827f65ec6d9dc9a4035a8 /java/client | |
| parent | 1e2b5e908b082b754f2971d34df7d4a22415f90c (diff) | |
| download | qpid-python-f2e1382c67f6acd9840d449e6de9a146cfef6f92.tar.gz | |
QPID-4608 Added code to handle TransportException and any other
RuntimeException.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1451362 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index f93b58f92f..d36badc9b7 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -1436,6 +1436,14 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic { throw toJMSException("Cannot create temporary queue",e); } + catch(TransportException e) + { + throw toJMSException("Cannot create temporary queue: " + e.getMessage(), e); + } + catch(Exception e) + { + throw new JMSAMQException("Cannot create temporary queue: " + e.getMessage(), e); + } } public TemporaryTopic createTemporaryTopic() throws JMSException |