qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From raj...@apache.org
Subject svn commit: r1163867 - /qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Date Wed, 31 Aug 2011 23:32:20 GMT
Author: rajith
Date: Wed Aug 31 23:32:20 2011
New Revision: 1163867

URL: http://svn.apache.org/viewvc?rev=1163867&view=rev
Log:
QPID-3461 The commit method implementation in AMQSession_0_10 now
handles the SessionException and throws a JMSException.

Modified:
    qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java

Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=1163867&r1=1163866&r2=1163867&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
(original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Wed Aug 31 23:32:20 2011
@@ -1007,6 +1007,13 @@ public class AMQSession_0_10 extends AMQ
             }
             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);



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message