[jboss-cvs] JBossAS SVN: r60867 - trunk/server/src/main/org/jboss/invocation/jrmp/server.

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

Author: bstansberry at jboss.com
Date: 2007-02-23 22:52:02 -0500 (Fri, 23 Feb 2007)
New Revision: 60867

Modified:
   trunk/server/src/main/org/jboss/invocation/jrmp/server/JRMPInvoker.java
Log:
[JBAS-4116] JRMPInvoker does not cache TransactionPropagationContextImporter

Modified: trunk/server/src/main/org/jboss/invocation/jrmp/server/JRMPInvoker.java
===================================================================
--- trunk/server/src/main/org/jboss/invocation/jrmp/server/JRMPInvoker.java	2007-02-24 02:36:51 UTC (rev 60866)
+++ trunk/server/src/main/org/jboss/invocation/jrmp/server/JRMPInvoker.java	2007-02-24 03:52:02 UTC (rev 60867)
@@ -57,7 +57,6 @@
 import org.jboss.security.SecurityDomain;
 import org.jboss.system.Registry;
 import org.jboss.system.ServiceMBeanSupport;
-import org.jboss.tm.TransactionPropagationContextImporter;
 import org.jboss.tm.TransactionPropagationContextUtil;
 
 /**
@@ -136,8 +135,6 @@
     */
    private MBeanServerAction serverAction = new MBeanServerAction();
 
-   private static TransactionPropagationContextImporter tpcImporter;
-
    public JRMPInvoker()
    {
       final JRMPInvoker delegate = this;
@@ -353,11 +350,10 @@
 
       InitialContext ctx = new InitialContext();
 
-      // FIXME marcf: This should not be here
-      // and the transaction propagation context importer
-      tpcImporter = TransactionPropagationContextUtil.getTPCImporter();
+      // Validate that there is a TransactionPropagationContextImporter
+      // bound in JNDI
+      TransactionPropagationContextUtil.getTPCImporter();
 
-
       // Set the transaction manager and transaction propagation
       // context factory of the GenericProxy class
 
@@ -589,7 +585,7 @@
    protected Transaction importTPC(Object tpc)
    {
       if (tpc != null)
-         return tpcImporter.importTransactionPropagationContext(tpc);
+         return TransactionPropagationContextUtil.importTPC(tpc);
       return null;
    }