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

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

Author: tfennelly
Date: 2010-04-06 09:46:20 -0400 (Tue, 06 Apr 2010)
New Revision: 32448

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPool.java
Log:
https://jira.jboss.org/jira/browse/JBESB-3264
JmsConnectionPool performs JNDI lookup for connection factory every time it obtains a session

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPool.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPool.java	2010-04-06 13:17:08 UTC (rev 32447)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/rosetta/pooling/JmsConnectionPool.java	2010-04-06 13:46:20 UTC (rev 32448)
@@ -106,7 +106,7 @@
     /**
      * The flag representing XA aware connections.
      */
-    private boolean isXAAware ;
+    private Boolean isXAAware ;
     /**
      * Flag signifying that the pool has been terminated.
      */
@@ -213,16 +213,16 @@
             addSessionPool();
         }
 
-        final Object factoryConnection ;
-        try
-        {
-            factoryConnection = getFactoryConnection() ;
+        if(isXAAware == null) {
+	        try
+	        {
+	            getFactoryConnection() ;
+	        }
+	        catch (final NamingContextException nce)
+	        {
+	            throw new ConnectionException("Unexpected exception accessing Naming Context", nce) ;
+	         }
         }
-        catch (final NamingContextException nce)
-        {
-            throw new ConnectionException("Unexpected exception accessing Naming Context", nce) ;
-        }
-        isXAAware = (factoryConnection instanceof XAConnectionFactory) ;
         
         final boolean transacted ;
         try {
@@ -319,6 +319,9 @@
         {
             NamingContextPool.releaseNamingContext(jndiContext) ;
         }
+
+        isXAAware = (factoryConnection instanceof XAConnectionFactory) ;
+
         return factoryConnection ;
     }