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

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

Author: gaol
Date: 2011-04-19 23:11:06 -0400 (Tue, 19 Apr 2011)
New Revision: 111213

Modified:
   projects/jboss-jca/trunk/rhq/src/test/java/org/jboss/jca/rhq/test/DsTestCase.java
Log:
[JBJCA-544] Basic tests on Pool.flush() and Pool.flush(true) that no exceptions thrown when calling.

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-04-19 19:14:27 UTC (rev 111212)
+++ projects/jboss-jca/trunk/rhq/src/test/java/org/jboss/jca/rhq/test/DsTestCase.java	2011-04-20 03:11:06 UTC (rev 111213)
@@ -21,6 +21,7 @@
  */
 package org.jboss.jca.rhq.test;
 
+import org.jboss.jca.core.api.connectionmanager.pool.Pool;
 import org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration;
 import org.jboss.jca.core.api.management.DataSource;
 import org.jboss.jca.core.api.management.ManagementRepository;
@@ -133,10 +134,7 @@
       ConfigurationUpdateReport updateConfigReport = new ConfigurationUpdateReport(config);
       configFacet.updateResourceConfiguration(updateConfigReport);
       
-      ManagementRepository manRepo = ManagementRepositoryManager.getManagementRepository();
-      List<DataSource> datasources = manRepo.getDataSources();
-      assertEquals(1, datasources.size());
-      DataSource ds = datasources.get(0);
+      DataSource ds = getDataSource();
       PoolConfiguration poolConfig = ds.getPoolConfiguration();
       
       assertEquals(5, poolConfig.getMinSize());
@@ -151,6 +149,49 @@
    }
    
    /**
+    * Gets the associated DataSource
+    * @return datasource
+    */
+   private DataSource getDataSource()
+   {
+      ManagementRepository manRepo = ManagementRepositoryManager.getManagementRepository();
+      List<DataSource> datasources = manRepo.getDataSources();
+      assertEquals(1, datasources.size());
+      DataSource ds = datasources.get(0);
+      return ds;
+   }
+   
+   /**
+    * test DataSource Pool.flush()
+    * 
+    * @throws Throwable exception
+    */
+   @Test
+   public void testDsPoolFlush() throws Throwable
+   {
+      DataSource ds = getDataSource();
+      Pool pool = ds.getPool();
+      pool.flush();
+      
+      // just not thrown exception for now.
+   }
+   
+   /**
+    * test DataSource Pool.flush(true)
+    * 
+    * @throws Throwable exception
+    */
+   @Test
+   public void testDsPoolFlushKill() throws Throwable
+   {
+      DataSource ds = getDataSource();
+      Pool pool = ds.getPool();
+      pool.flush(true);
+      
+      // just not thrown exception for now.
+   }
+   
+   /**
     * Lifecycle start, before the suite is executed
     * @throws Throwable throwable exception 
     */