[jboss-svn-commits] JBL Code SVN: r32644 - labs/jbosstm/workspace/whitingjr/trunk/performance/src/main/java/org/jboss/jbossts/performance/connectionmanager.

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

Author: whitingjr
Date: 2010-04-25 11:09:27 -0400 (Sun, 25 Apr 2010)
New Revision: 32644

Modified:
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/main/java/org/jboss/jbossts/performance/connectionmanager/LocalTXCachedDataSource.java
Log:
Fixed connection manager.

Modified: labs/jbosstm/workspace/whitingjr/trunk/performance/src/main/java/org/jboss/jbossts/performance/connectionmanager/LocalTXCachedDataSource.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/performance/src/main/java/org/jboss/jbossts/performance/connectionmanager/LocalTXCachedDataSource.java	2010-04-25 14:18:45 UTC (rev 32643)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/main/java/org/jboss/jbossts/performance/connectionmanager/LocalTXCachedDataSource.java	2010-04-25 15:09:27 UTC (rev 32644)
@@ -22,8 +22,10 @@
 
 package org.jboss.jbossts.performance.connectionmanager;
 
+import java.lang.reflect.Field;
 import java.sql.Connection;
 
+import javax.naming.InitialContext;
 import javax.resource.ResourceException;
 import javax.resource.spi.ConnectionRequestInfo;
 import javax.resource.spi.ManagedConnectionFactory;
@@ -43,9 +45,12 @@
    public void start() throws Exception
    {
       super.start();
-      this.txConnManager = (TxConnectionManager)FieldUtils.readDeclaredField(this, "connectionManager", true);
-      Object datasource = txConnManager.getPoolingStrategy().getManagedConnectionFactory().createConnectionFactory(new CachedLocalTxConnectionManager());
-      FieldUtils.writeDeclaredField(this, "datasource", datasource, true);
+      this.initialContext =  new InitialContext(initialContextProperties);
+      Field txConnManagerField = FieldUtils.getDeclaredField(LocalTxDataSource.class, "connectionManager", true);
+      this.txConnManager = (TxConnectionManager)FieldUtils.readField(txConnManagerField, this, true); 
+      Object newDatasource = txConnManager.getPoolingStrategy().getManagedConnectionFactory().createConnectionFactory(new CachedLocalTxConnectionManager());
+      Field datasourceField = FieldUtils.getDeclaredField(LocalTxDataSource.class, "datasource", true);
+      FieldUtils.writeField(datasourceField, this, newDatasource, true); 
       bindConnectionFactory();
    }