[jboss-cvs] JBossAS SVN: r111324 - projects/jboss-jca/trunk/rhq/src/test/java/org/jboss/jca/rhq/test.

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

Author: gaol
Date: 2011-05-09 21:50:52 -0400 (Mon, 09 May 2011)
New Revision: 111324

Modified:
   projects/jboss-jca/trunk/rhq/src/test/java/org/jboss/jca/rhq/test/DsTestCase.java
Log:
[JBJCA-561] tests Pool.flush(true) on PoolStatistics values

Modified: projects/jboss-jca/trunk/rhq/src/test/java/org/jboss/jca/rhq/test/DsTestCase.java
===================================================================
--- projects/jboss-jca/trunk/rhq/src/test/java/org/jboss/jca/rhq/test/DsTestCase.java	2011-05-09 21:03:52 UTC (rev 111323)
+++ projects/jboss-jca/trunk/rhq/src/test/java/org/jboss/jca/rhq/test/DsTestCase.java	2011-05-10 01:50:52 UTC (rev 111324)
@@ -23,6 +23,7 @@
 
 import org.jboss.jca.core.api.connectionmanager.pool.Pool;
 import org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration;
+import org.jboss.jca.core.api.connectionmanager.pool.PoolStatistics;
 import org.jboss.jca.core.api.management.DataSource;
 import org.jboss.jca.core.api.management.ManagementRepository;
 import org.jboss.jca.rhq.core.ManagementRepositoryManager;
@@ -30,10 +31,14 @@
 
 import java.io.File;
 import java.net.URL;
+import java.sql.Connection;
 import java.util.List;
 
+import javax.naming.InitialContext;
+
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import org.rhq.core.domain.configuration.Configuration;
@@ -257,13 +262,27 @@
     * 
     * @throws Throwable exception
     */
+   @Ignore
    @Test
    public void testDsPoolFlushKill() throws Throwable
    {
       DataSource ds = getDataSource();
       Pool pool = ds.getPool();
-      pool.flush(true);
+      // set prefill to false
+      ds.getPoolConfiguration().setPrefill(false);
+      PoolStatistics poolStatistics = pool.getStatistics();
       
+      InitialContext context = new InitialContext();
+      javax.sql.DataSource sqlDS = (javax.sql.DataSource)context.lookup(ds.getJndiName());
+      Connection conn = sqlDS.getConnection();
+      
+      assertEquals(1, poolStatistics.getActiveCount());
+      
+      pool.flush(true);  // it flushes all connections from the pool.
+      
+      assertEquals(0, poolStatistics.getActiveCount());
+      
+      conn.close();
       // just not thrown exception for now.
    }