User: patriot1burke
Date: 01/09/26 20:15:56
Modified: src/main/org/jboss/ejb/plugins/jrmp/server
JRMPContainerInvokerHA.java
Log:
no message
Revision Changes Path
1.4 +78 -63
jbossmx/src/main/org/jboss/ejb/plugins/jrmp/server/JRMPContainerInvokerHA.java
Index: JRMPContainerInvokerHA.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmx/src/main/org/jboss/ejb/plugins/jrmp/server/JRMPContainerInvokerHA.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- JRMPContainerInvokerHA.java 2001/09/11 18:39:55 1.3
+++ JRMPContainerInvokerHA.java 2001/09/27 03:15:56 1.4
@@ -1,100 +1,115 @@
/*
- * JBoss, the OpenSource J2EE WebOS
+ * JBoss, the OpenSource J2EE webOS
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
-
package org.jboss.ejb.plugins.jrmp.server;
-import org.jboss.logging.Logger;
+import java.io.IOException;
+import java.lang.reflect.Method;
+import java.net.UnknownHostException;
+import java.rmi.ServerException;
+import java.rmi.RemoteException;
+import java.rmi.MarshalledObject;
+import java.rmi.server.RemoteServer;
+import java.rmi.server.RMIClientSocketFactory;
+import java.rmi.server.RMIServerSocketFactory;
+import java.rmi.server.UnicastRemoteObject;
+import java.security.Principal;
+import java.util.Collection;
+import java.util.Map;
+import java.util.HashMap;
+
+import javax.ejb.EJBMetaData;
+import javax.ejb.EJBHome;
+import javax.ejb.EJBObject;
+import javax.naming.Name;
+import javax.naming.InitialContext;
+import javax.naming.Context;
+import javax.naming.NamingException;
+import javax.naming.NameNotFoundException;
+import javax.transaction.Transaction;
+import javax.transaction.TransactionManager;
+
+import org.jboss.ejb.Container;
+import org.jboss.ejb.ContainerInvokerContainer;
+import org.jboss.ejb.ContainerInvoker;
import org.jboss.ejb.DeploymentException;
+import org.jboss.ejb.MethodInvocation;
+import org.jboss.ejb.plugins.jrmp.interfaces.RemoteMethodInvocation;
+import org.jboss.ejb.plugins.jrmp.interfaces.HomeHandleImpl;
+import org.jboss.ejb.plugins.jrmp.interfaces.GenericProxy;
+import org.jboss.ejb.plugins.jrmp.interfaces.ContainerRemote;
+import org.jboss.ejb.plugins.jrmp.interfaces.EJBMetaDataImpl;
+import org.jboss.logging.Logger;
import org.jboss.metadata.XmlLoadable;
import org.jboss.metadata.MetaData;
import org.jboss.metadata.EntityMetaData;
import org.jboss.metadata.SessionMetaData;
+import org.jboss.security.SecurityAssociation;
+import org.jboss.tm.TransactionPropagationContextFactory;
+import org.jboss.tm.TransactionPropagationContextImporter;
import org.w3c.dom.Element;
-
-
+import org.jboss.ha.HARMIServerImpl;
+import org.jboss.ha.HAPartition;
/**
- * Specialized from JRMPContainerInvoker v.1.35 for HA use in SLSB
- *
- * @see JRMPContainerInvoker
- * @author Rickard �berg ([EMAIL PROTECTED])
- * @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
- * @author <a href="mailto:[EMAIL PROTECTED]";>Sacha Labourey</a>
- * @version $Revision: 1.3 $
- *
- * <p><b>Revisions:</b>
+ * The <code>ContainerInvoker</code> for invoking enterprise beans
+ * over the JRMP invocation transport.
*
- * <p><b>20010819 Sacha Labourey:</b>
- * <ul>
- * <li> First import of sources
- * </ul>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Rickard �berg</a>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Sebastien Alborini</a>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Juha Lindfors</a>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Ole Husgaard</a>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Scott Stark</a>
+ * @version $Revision: 1.4 $
*/
-
public class JRMPContainerInvokerHA extends JRMPContainerInvoker
{
- static Logger log = Logger.create(JRMPContainerInvokerHA.class);
-
- /** Creates new JRMPContainerInvokerHA */
- public JRMPContainerInvokerHA ()
- {
- super ();
- }
+ protected String partitionName = "DefaultPartition";
- public void start ()
- throws Exception
+ protected void exportCI() throws Exception
{
- super.start ();
- ciDelegate.start ();
+
((org.jboss.ejb.plugins.jrmp13.server.JRMPContainerInvokerHA)ciDelegate).start();
}
- public void stop ()
+ protected void unexportCI() throws Exception
{
- super.stop ();
- ciDelegate.stop ();
+
((org.jboss.ejb.plugins.jrmp13.server.JRMPContainerInvokerHA)ciDelegate).stop();
}
- public void destroy ()
+ protected void createCIDelegate() throws DeploymentException
{
- super.destroy ();
- ciDelegate.destroy ();
- }
-
-
- // XmlLoadable implementation
- public void importXml (Element element) throws DeploymentException
- {
- String opt = MetaData.getElementContent (MetaData.getUniqueChild (element,
"Optimized"));
- optimize = Boolean.valueOf (opt).booleanValue ();
-
- if ((System.getProperty ("java.vm.version").compareTo ("1.3") >= 0)) jdk122 =
false;
- else jdk122 = true;
-
// Create delegate depending on JDK version
if (jdk122)
{
- ciDelegate = new
org.jboss.ejb.plugins.jrmp12.server.JRMPContainerInvokerHA (this);
- } else
+ throw new DeploymentException("NOT IMPLEMENTED");
+ }
+ else
{
- ciDelegate = new
org.jboss.ejb.plugins.jrmp13.server.JRMPContainerInvokerHA (this);
+ ciDelegate = new
org.jboss.ejb.plugins.jrmp13.server.JRMPContainerInvokerHA(this, partitionName);
}
+ }
- try
- {
- String port = MetaData.getElementContent (MetaData.getUniqueChild
(element, "RMIObjectPort"));
- rmiPort = Integer.parseInt (port);
- } catch(NumberFormatException e)
- {
- rmiPort = ANONYMOUS_PORT;
- } catch(DeploymentException e)
+ // XmlLoadable implementation
+ public void importXml(Element element) throws DeploymentException
+ {
+ Element partitionElement = MetaData.getUniqueChild(element, "HAPartition");
+ if (partitionElement != null)
{
- rmiPort = ANONYMOUS_PORT;
+ String partition = MetaData.getElementContent(partitionElement);
+ if (partition != null)
+ {
+ this.partitionName = partition;
+ }
}
- log.debug ("Container Invoker RMI Port='"+(rmiPort == ANONYMOUS_PORT ?
"Anonymous" : Integer.toString (rmiPort))+"'");
- log.debug ("Container Invoker Optimize='"+optimize+"'");
+ super.importXml(element);
}
-
+
+ // Package protected ---------------------------------------------
+
+ // Inner classes -------------------------------------------------
}
+
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
