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

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

Author: jhalliday
Date: 2009-01-19 10:21:15 -0500 (Mon, 19 Jan 2009)
New Revision: 24789

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:
expose TransactionSynchronizationRegistry as TransactionManagerService property.  JBTM-470


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	2009-01-19 14:49:52 UTC (rev 24788)
+++ labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerService.java	2009-01-19 15:21:15 UTC (rev 24789)
@@ -63,6 +63,7 @@
 import javax.naming.NamingException;
 import javax.transaction.TransactionManager;
 import javax.transaction.UserTransaction;
+import javax.transaction.TransactionSynchronizationRegistry;
 import java.net.Socket;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
@@ -392,6 +393,17 @@
     }
 
     /**
+     * Retrieve a reference ot the JTA TransactionSynchronizationRegistry.
+     *
+     * @return a reference to the JTA TransactionSynchronizationRegistry.
+     */
+    public TransactionSynchronizationRegistry getTransactionSynchronizationRegistry()
+    {
+        // rely on the imple being stateless:
+        return new TransactionSynchronizationRegistryImple();
+    }
+
+    /**
      * Get the XA Terminator
      *
      * @return the XA Terminator

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	2009-01-19 14:49:52 UTC (rev 24788)
+++ labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jta/TransactionManagerServiceMBean.java	2009-01-19 15:21:15 UTC (rev 24789)
@@ -36,6 +36,7 @@
 
 import javax.transaction.TransactionManager;
 import javax.transaction.UserTransaction;
+import javax.transaction.TransactionSynchronizationRegistry;
 import java.net.InetAddress;
 
 /**
@@ -113,6 +114,13 @@
     public UserTransaction getUserTransaction();
 
     /**
+     * Retrieve a reference to the JTA TransactionSynchronizationRegistry.
+     *
+     * @return a reference to the JTA TransactionSynchronizationRegistry.
+     */
+    public TransactionSynchronizationRegistry getTransactionSynchronizationRegistry();
+
+    /**
      * This method has been put in here so that it is compatible with the JBoss standard Transaction Manager.
      * As we do not support exception formatters just display a warning for the moment.
      */

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	2009-01-19 14:49:52 UTC (rev 24788)
+++ labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerService.java	2009-01-19 15:21:15 UTC (rev 24789)
@@ -71,6 +71,7 @@
 import javax.naming.NamingException;
 import javax.transaction.TransactionManager;
 import javax.transaction.UserTransaction;
+import javax.transaction.TransactionSynchronizationRegistry;
 import java.net.Socket;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
@@ -436,6 +437,17 @@
     }
 
     /**
+     * Retrieve a reference ot the JTA TransactionSynchronizationRegistry.
+     *
+     * @return a reference to the JTA TransactionSynchronizationRegistry.
+     */
+    public TransactionSynchronizationRegistry getTransactionSynchronizationRegistry()
+    {
+        // rely on the imple being stateless:
+        return new TransactionSynchronizationRegistryImple();
+    }
+    
+    /**
      * Get the XA Terminator
      *
      * @return the XA Terminator

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	2009-01-19 14:49:52 UTC (rev 24788)
+++ labs/jbosstm/trunk/atsintegration/classes/com/arjuna/ats/jbossatx/jts/TransactionManagerServiceMBean.java	2009-01-19 15:21:15 UTC (rev 24789)
@@ -35,6 +35,7 @@
 
 import javax.transaction.TransactionManager;
 import javax.transaction.UserTransaction;
+import javax.transaction.TransactionSynchronizationRegistry;
 import java.net.InetAddress;
 
 /**
@@ -98,6 +99,13 @@
     public TransactionManager getTransactionManager();
 
     /**
+     * Retrieve a reference to the JTA TransactionSynchronizationRegistry.
+     *
+     * @return a reference to the JTA TransactionSynchronizationRegistry.
+     */
+    public TransactionSynchronizationRegistry getTransactionSynchronizationRegistry();
+
+    /**
      * Get the XA Terminator
      *
      * @return the XA Terminator