1 files changed, 7 insertions, 0 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
index 75d96d67af..b5868cd235 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
+++ b/qpid/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);