[jboss-cvs] JBossAS SVN: r103342 - projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb.

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

Author: wolfc
Date: 2010-03-31 11:06:46 -0400 (Wed, 31 Mar 2010)
New Revision: 103342

Modified:
   projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb/RemoteProducerFactory.java
Log:
EJBTHREE-2066: make sure we register before exposing ourselves

Modified: projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb/RemoteProducerFactory.java
===================================================================
--- projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb/RemoteProducerFactory.java	2010-03-31 14:56:15 UTC (rev 103341)
+++ projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb/RemoteProducerFactory.java	2010-03-31 15:06:46 UTC (rev 103342)
@@ -21,13 +21,6 @@
  */
 package org.jboss.ejb3.mdb;
 
-import java.util.Hashtable;
-
-import javax.jms.ConnectionFactory;
-import javax.jms.Destination;
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
-
 import org.jboss.aop.Dispatcher;
 import org.jboss.aop.advice.Interceptor;
 import org.jboss.aspects.remoting.Remoting;
@@ -37,6 +30,12 @@
 import org.jboss.ejb3.proxy.impl.remoting.ProxyRemotingUtils;
 import org.jboss.util.naming.Util;
 
+import javax.jms.ConnectionFactory;
+import javax.jms.Destination;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+import java.util.Hashtable;
+
 /**
  * comment
  *
@@ -81,7 +80,7 @@
 
    public void start() throws Exception
    {
-      super.start();
+      Dispatcher.singleton.registerTarget(jndiName + PROXY_FACTORY_NAME, this);
       Class[] interfaces = {ProxyFactory.class};
       Object factoryProxy = Remoting.createPojiProxy(jndiName + PROXY_FACTORY_NAME, interfaces, ProxyRemotingUtils.getDefaultClientBinding());
       try
@@ -93,7 +92,7 @@
          namingException.setRootCause(e);
          throw namingException;
       }
-      Dispatcher.singleton.registerTarget(jndiName + PROXY_FACTORY_NAME, this);
+      super.start();
    }
 
    public void stop() throws Exception