[jboss-svn-commits] JBL Code SVN: r31063 - labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/auction/test/basic.

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

Author: whitingjr
Date: 2010-01-13 10:11:55 -0500 (Wed, 13 Jan 2010)
New Revision: 31063

Modified:
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/auction/test/basic/ProfiledStateTransitions.java
Log:
Added support last resource commit optimisation.


Modified: labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/auction/test/basic/ProfiledStateTransitions.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/auction/test/basic/ProfiledStateTransitions.java	2010-01-13 15:10:28 UTC (rev 31062)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/auction/test/basic/ProfiledStateTransitions.java	2010-01-13 15:11:55 UTC (rev 31063)
@@ -72,8 +72,6 @@
 import org.w3c.dom.NodeList;
 import org.xml.sax.InputSource;
 
-import com.arjuna.ats.arjuna.coordinator.TxControl;
-
 import auction.model.Address;
 import auction.model.AddressEntity;
 import auction.model.Auditable;
@@ -94,6 +92,10 @@
 import auction.model.ShipmentState;
 import auction.model.User;
 import auction.test.EJB3IntegrationTest;
+
+import com.arjuna.ats.arjuna.common.arjPropertyManager;
+import com.arjuna.ats.arjuna.coordinator.TxControl;
+import com.arjuna.ats.jta.common.jtaPropertyManager;
 @SqlResultSetMapping(name = "PriceSellerResult", columns =
 {@ColumnResult(name = "IP"), @ColumnResult(name = "SID")
 
@@ -262,9 +264,9 @@
    
    @BeforeTest(groups = "integration-warmup")
    @Parameters(
-   {"deploy_beans_xml", "scan_classpath", "jndi_datasource_A", "jndi_datasource_B", "jndi_name_emf_A", "jndi_name_emf_B", "jndi_name_usertx_A", "jndi_name_usertx_B", "session_jndi_A", "session_jndi_B", "invoke_optional_write", "transaction_timeout"})
+   {"deploy_beans_xml", "scan_classpath", "jndi_datasource_A", "jndi_datasource_B", "jndi_name_emf_A", "jndi_name_emf_B", "jndi_name_usertx_A", "jndi_name_usertx_B", "session_jndi_A", "session_jndi_B", "invoke_optional_write", "transaction_timeout", "use_lrco"})
    public void startContainer(String deployBeansXml, String scanClasspath, String jndiDatasourceA, String jndiDatasourceB, String jndiNameEMF_A, String jndiNameEMF_B,
-         String jndiNameUserTxA, String jndiNameUserTxB, String jndiNameHSF_A, String jndiNameHSF_B, String flag, String transactionTimeout) throws Exception
+         String jndiNameUserTxA, String jndiNameUserTxB, String jndiNameHSF_A, String jndiNameHSF_B, String flag, String transactionTimeout, String useLRCO) throws Exception
    {
       // Set configuration options from TestNG parameters
       JNDI_DATASOURCE = jndiDatasourceA;
@@ -282,7 +284,15 @@
       {
          TxControl.setDefaultTimeout(Integer.parseInt(transactionTimeout));
       }
-
+      
+      /* Configure the Last Resource Commit Optimisation */
+      if (StringUtils.isNotEmpty(useLRCO) && Boolean.TRUE.equals(Boolean.parseBoolean(useLRCO)))
+      {
+         arjPropertyManager.getCoreEnvironmentBean().setAllowMultipleLastResources(true);
+         arjPropertyManager.getCoreEnvironmentBean().setDisableMultipleLastResourcesWarning(true);
+         jtaPropertyManager.getJTAEnvironmentBean().setLastResourceOptimisationInterface("org.jboss.tm.LastResource");
+      }
+      
       // Boot the JBoss Microcontainer with EJB3 settings, automatically
       // loads ejb3-interceptors-aop.xml and embedded-jboss-beans.xml
       EJB3StandaloneBootstrap.boot(null);
@@ -292,12 +302,12 @@
 
       // Deploy all EJBs found on classpath (slow, scans all)
       //EJB3StandaloneBootstrap.scanClasspath();
-
+      
       // Deploy all EJBs found on classpath (fast, scans only build directory)
       // This is a relative location, matching the substring end of one of java.class.path locations!
       // Print out System.getProperty("java.class.path") to understand this...
       EJB3StandaloneBootstrap.scanClasspath(scanClasspath.replace("/", File.separator));
-
+      
       // Create InitialContext from jndi.properties
       jndi = new InitialContext();