[jboss-svn-commits] JBL Code SVN: r12148 - labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers.

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

Author: kevin.conner at jboss.com
Date: 2007-05-25 14:43:52 -0400 (Fri, 25 May 2007)
New Revision: 12148

Modified:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java
Log:
Release session on error: JBESB-577

Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java	2007-05-25 18:42:16 UTC (rev 12147)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java	2007-05-25 18:43:52 UTC (rev 12148)
@@ -388,6 +388,7 @@
 	private void createMessageConsumer () throws CourierException, ConfigurationException, MalformedEPRException
 	{
         Context oJndiCtx = null;
+        boolean success = false ;
 		try
 		{
             Properties environment = _epr.getJndiEnvironment();
@@ -431,6 +432,7 @@
 			} else {
 				throw new CourierException("Unknown destination type");
             }
+                        success = true ;
 		}
         catch (ConnectionException cex)
         {
@@ -450,6 +452,18 @@
 		{
 			throw new MalformedEPRException(ex);
 		}
+                finally
+                {
+                    if (!success)
+                    {
+                        if (_jmsSession != null)
+                        {
+                            _pool.closeSession(_jmsSession) ;
+                            _jmsSession = null ;
+                        }
+                        _pool = null ;
+                    }
+                }
 	} // ________________________________