[jboss-svn-commits] JBL Code SVN: r8923 - in labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx: jts and 1 other directory.

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

Author: kevin.conner at jboss.com
Date: 2007-01-19 11:46:51 -0500 (Fri, 19 Jan 2007)
New Revision: 8923

Modified:
   labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerService.java
   labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerServiceMBean.java
   labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerService.java
   labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerServiceMBean.java
Log:
Allow for specification of the object store via the MBean: JBTM-186

Modified: labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerService.java
===================================================================
--- labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerService.java	2007-01-19 16:08:48 UTC (rev 8922)
+++ labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerService.java	2007-01-19 16:46:51 UTC (rev 8923)
@@ -96,6 +96,7 @@
 
 	private RecoveryManager _recoveryManager;
     private boolean _runRM = true;
+    private int timeout ;
 
     /**
      * Use the short class name as the default for the service name.
@@ -125,6 +126,11 @@
         System.setProperty(com.arjuna.ats.tsmx.TransactionServiceMX.AGENT_IMPLEMENTATION_PROPERTY,
                 com.arjuna.ats.internal.jbossatx.agent.LocalJBossAgentImpl.class.getName());
         System.setProperty(Environment.LAST_RESOURCE_OPTIMISATION_INTERFACE, LastResource.class.getName()) ;
+        
+        if (timeout != 0)
+        {
+            TxControl.setDefaultTimeout(timeout);
+        }
 
         /** Register management plugin **/
         com.arjuna.ats.arjuna.common.arjPropertyManager.propertyManager.addManagementPlugin(new PropertyServiceJMXPlugin());
@@ -295,10 +301,7 @@
      */
     public void setTransactionTimeout(int timeout) throws javax.transaction.SystemException
     {
-        if (timeout != 0)
-        {
-            TxControl.setDefaultTimeout(timeout);
-        }
+        this.timeout = timeout ;
     }
 
     /**
@@ -426,6 +429,15 @@
     {
         _runRM = runRM;
     }
+    
+    /**
+     * Set the object store directory.
+     * @param objectStoreDir The object store directory.
+     */
+    public void setObjectStoreDir(final String objectStoreDir)
+    {
+	System.setProperty(com.arjuna.ats.arjuna.common.Environment.OBJECTSTORE_DIR, objectStoreDir) ;
+    }
 
     private void registerNotification()
         throws InstanceNotFoundException

Modified: labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerServiceMBean.java
===================================================================
--- labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerServiceMBean.java	2007-01-19 16:08:48 UTC (rev 8922)
+++ labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerServiceMBean.java	2007-01-19 16:46:51 UTC (rev 8923)
@@ -138,5 +138,11 @@
      * @param runRM
      */
     public void setRunInVMRecoveryManager(boolean runRM);
+    
+    /**
+     * Set the object store directory.
+     * @param objectStoreDir The object store directory.
+     */
+    public void setObjectStoreDir(final String objectStoreDir) ;
 }
 

Modified: labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerService.java
===================================================================
--- labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerService.java	2007-01-19 16:08:48 UTC (rev 8922)
+++ labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerService.java	2007-01-19 16:46:51 UTC (rev 8923)
@@ -440,6 +440,15 @@
     {
         _runRM = runRM;
     }
+    
+    /**
+     * Set the object store directory.
+     * @param objectStoreDir The object store directory.
+     */
+    public void setObjectStoreDir(final String objectStoreDir)
+    {
+	System.setProperty(com.arjuna.ats.arjuna.common.Environment.OBJECTSTORE_DIR, objectStoreDir) ;
+    }
 
     private void registerNotification()
         throws InstanceNotFoundException

Modified: labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerServiceMBean.java
===================================================================
--- labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerServiceMBean.java	2007-01-19 16:08:48 UTC (rev 8922)
+++ labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerServiceMBean.java	2007-01-19 16:46:51 UTC (rev 8923)
@@ -137,6 +137,12 @@
      * @param runRM
      */
     public void setRunInVMRecoveryManager(boolean runRM);
+    
+    /**
+     * Set the object store directory.
+     * @param objectStoreDir The object store directory.
+     */
+    public void setObjectStoreDir(final String objectStoreDir) ;
 
     /**
      * Set the flag indicating whether the propagation context should always be propagated.