[jboss-svn-commits] JBL Code SVN: r23963 - labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms.

[jboss-svn-commits at lists.jboss.org]

Author: beve
Date: 2008-11-19 08:53:18 -0500 (Wed, 19 Nov 2008)
New Revision: 23963

Modified:
   labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsInboundRouter.java
   labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsOutboundRouter.java
Log:
updated the catch clauses to catch intercept throwable, to perform clean up, then rethrow.


Modified: labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsInboundRouter.java
===================================================================
--- labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsInboundRouter.java	2008-11-19 13:23:46 UTC (rev 23962)
+++ labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsInboundRouter.java	2008-11-19 13:53:18 UTC (rev 23963)
@@ -236,7 +236,7 @@
             RouterUtil.closeJmsSession(jmsSession);
             throw e;
         }
-        catch (final Exception t)
+        catch (final Throwable t)
         {
             RouterUtil.closeJmsSession(jmsSession);
             throw (JMSException) (new JMSException("Unexpected exception while connecting JmsMesssageListener.").initCause(t));

Modified: labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsOutboundRouter.java
===================================================================
--- labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsOutboundRouter.java	2008-11-19 13:23:46 UTC (rev 23962)
+++ labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsOutboundRouter.java	2008-11-19 13:53:18 UTC (rev 23963)
@@ -263,7 +263,7 @@
             RouterUtil.closeJmsSession(jmsSession);
             throw e;
         }
-        catch (final Exception t)
+        catch (final Throwable t)
         {
             RouterUtil.closeJmsSession(jmsSession);
             throw (JMSException) (new JMSException("Unexpected exception while connecting JmsMesssageSender.").initCause(t));