[jboss-svn-commits] JBL Code SVN: r25229 - in labs/jbosstm/trunk/XTS: sar/META-INF and 1 other directories.

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

Author: adinn
Date: 2009-02-11 11:30:52 -0500 (Wed, 11 Feb 2009)
New Revision: 25229

Modified:
   labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/util/TransportTimer.java
   labs/jbosstm/trunk/XTS/sar/META-INF/jboss-beans.xml
   labs/jbosstm/trunk/XTS/sar/src/org/jboss/jbossts/XTSService.java
Log:
added bean properties to XTSService allowing setting of AT/BA transport timer properties in jboss-beans.xml -- fixes JBTM-487

Modified: labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/util/TransportTimer.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/util/TransportTimer.java	2009-02-11 15:36:33 UTC (rev 25228)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/src/com/arjuna/webservices/util/TransportTimer.java	2009-02-11 16:30:52 UTC (rev 25229)
@@ -78,7 +78,7 @@
      * Set the initial transport period.
      * @param period The transport period in milliseconds.
      */
-    public static void setInitialTransportPeriod(final long period)
+    public static void setTransportPeriod(final long period)
     {
        PERIOD = period ;
     }

Modified: labs/jbosstm/trunk/XTS/sar/META-INF/jboss-beans.xml
===================================================================
--- labs/jbosstm/trunk/XTS/sar/META-INF/jboss-beans.xml	2009-02-11 15:36:33 UTC (rev 25228)
+++ labs/jbosstm/trunk/XTS/sar/META-INF/jboss-beans.xml	2009-02-11 16:30:52 UTC (rev 25229)
@@ -31,6 +31,12 @@
            </value-factory>
         </property>
 
+        <!-- uncomment to configure transport timing properties -->
+        <!--
+        <property name="initialTransportPeriod">5000</property>
+        <property name="maximumTransportPeriod">300000</property>
+        <property name="transportTimeout">30000</property>
+        -->
    </bean>
 
 </deployment>
\ No newline at end of file

Modified: labs/jbosstm/trunk/XTS/sar/src/org/jboss/jbossts/XTSService.java
===================================================================
--- labs/jbosstm/trunk/XTS/sar/src/org/jboss/jbossts/XTSService.java	2009-02-11 15:36:33 UTC (rev 25228)
+++ labs/jbosstm/trunk/XTS/sar/src/org/jboss/jbossts/XTSService.java	2009-02-11 16:30:52 UTC (rev 25229)
@@ -76,6 +76,7 @@
 //import com.arjuna.webservices.wsaddr.policy.AddressingPolicy;
 //import com.arjuna.wst.messaging.*;
 import com.arjuna.ats.arjuna.recovery.RecoveryManager;
+import com.arjuna.webservices.util.TransportTimer;
 
 import javax.management.MBeanServer;
 import java.net.InetAddress;
@@ -403,4 +404,53 @@
     }
 
     int httpsPort = 0;
+
+    // transport timing property reads/writes are redirected to the TransportTimer class
+    // however we cap the period settings to a minimum of 5 seconds and the timeout setting
+    // to a minimum of 10 seconds
+
+    private static final long MIN_PERIOD = 5 * 1000;
+    private static final long MIN_TIMEOUT = 10 * 1000;
+
+    public long getInitialTransportPeriod()
+    {
+        return TransportTimer.getTransportPeriod();
+    }
+
+    public void setInitialTransportPeriod(long initialTransportPeriod)
+    {
+        if (initialTransportPeriod > MIN_PERIOD) {
+            TransportTimer.setTransportPeriod(initialTransportPeriod);
+        } else {
+            TransportTimer.setTransportPeriod(MIN_PERIOD);
+        }
+    }
+
+    public long getMaximumTransportPeriod()
+    {
+        return TransportTimer.getMaximumTransportPeriod();
+    }
+
+    public void setMaximumTransportPeriod(long maximumTransportPeriod)
+    {
+        if (maximumTransportPeriod > MIN_PERIOD) {
+            TransportTimer.setMaximumTransportPeriod(maximumTransportPeriod);
+        } else {
+            TransportTimer.setMaximumTransportPeriod(MIN_PERIOD);
+        }
+    }
+
+    public long getTransportTimeout()
+    {
+        return TransportTimer.getTransportTimeout();
+    }
+
+    public void setTransportTimeout(long transportTimeout)
+    {
+        if (transportTimeout > MIN_TIMEOUT) {
+            TransportTimer.setTransportTimeout(transportTimeout);
+        } else {
+            TransportTimer.setTransportTimeout(MIN_TIMEOUT);
+        }
+    }
 }
\ No newline at end of file