[jboss-cvs] JBossAS SVN: r101195 - projects/jboss-jca/trunk/deployers/src/main/java/org/jboss/jca/deployers/fungal.

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

Author: jesper.pedersen
Date: 2010-02-19 22:19:49 -0500 (Fri, 19 Feb 2010)
New Revision: 101195

Modified:
   projects/jboss-jca/trunk/deployers/src/main/java/org/jboss/jca/deployers/fungal/RADeployer.java
Log:
Hard code the pool parameters for now, by Scott Marlow

Modified: projects/jboss-jca/trunk/deployers/src/main/java/org/jboss/jca/deployers/fungal/RADeployer.java
===================================================================
--- projects/jboss-jca/trunk/deployers/src/main/java/org/jboss/jca/deployers/fungal/RADeployer.java	2010-02-20 03:17:40 UTC (rev 101194)
+++ projects/jboss-jca/trunk/deployers/src/main/java/org/jboss/jca/deployers/fungal/RADeployer.java	2010-02-20 03:19:49 UTC (rev 101195)
@@ -26,6 +26,8 @@
 import org.jboss.jca.common.util.LocalConnectionFactoryBuilder;
 import org.jboss.jca.core.api.CloneableBootstrapContext;
 import org.jboss.jca.core.connectionmanager.notx.NoTxConnectionManager;
+import org.jboss.jca.core.connectionmanager.pool.PoolParams;
+import org.jboss.jca.core.connectionmanager.pool.strategy.OnePool;
 import org.jboss.jca.deployers.common.validator.Failure;
 import org.jboss.jca.deployers.common.validator.FailureHelper;
 import org.jboss.jca.deployers.common.validator.Key;
@@ -379,8 +381,15 @@
                         beanValidationObjects.add(mcf);
                         associationObjects.add(mcf);
 
+                        // TODO: add proper configuration and use it (support TxConnectionManager as well)
+                        NoTxConnectionManager noTxCm = new NoTxConnectionManager();
+                        PoolParams poolParams = new PoolParams();
+                        OnePool onePool = new OnePool(mcf, poolParams, true);
+                        onePool.setConnectionListenerFactory(noTxCm);
+                        noTxCm.setPoolingStrategy(onePool);
+                        
                         // ConnectionFactory
-                        Object cf = mcf.createConnectionFactory(new NoTxConnectionManager());
+                        Object cf = mcf.createConnectionFactory(noTxCm);
 
                         if (trace)
                         {