From cff63cb1718f0ca04f7c0df0e82ac10ae664c2a0 Mon Sep 17 00:00:00 2001
From: Rajith Muditha Attapattu <rajith@apache.org>
Date: Wed, 31 Aug 2011 23:32:20 +0000
Subject: 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
---
 .../src/main/java/org/apache/qpid/client/AMQSession_0_10.java      | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'java/client/src')

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);
-- 
cgit v1.2.1