QPID-3461 The commit method implementation in AMQSession_0_10 now

handles the SessionException and throws a JMSException.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1163867 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 0 deletions

diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
index 75d96d67af..b5868cd235 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
@@ -1007,6 +1007,13 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic
             }
             sendCommit();
         }
+        catch(SessionException e)
+        {
+            JMSException ex = new JMSException("Session exception occured while trying to commit");
+            ex.initCause(e);
+            ex.setLinkedException(e);
+            throw ex;
+        }
         catch (AMQException e)
         {
             throw new JMSAMQException("Failed to commit: " + e.getMessage(), e);