User: slaboure Date: 02/01/14 12:35:59 Modified: src/main/org/jboss/invocation/jrmp/server JRMPInvoker.java Log: Added an accessor for the RemoteStub that is obtained once the RemoteServer is exported. This is needed for clustering: directly serializaing the RemoteServer to the other nodes will fail. Revision Changes Path 1.6 +16 -3 jboss/src/main/org/jboss/invocation/jrmp/server/JRMPInvoker.java Index: JRMPInvoker.java =================================================================== RCS file: /cvsroot/jboss/jboss/src/main/org/jboss/invocation/jrmp/server/JRMPInvoker.java,v retrieving revision 1.5 retrieving revision 1.6 diff -u -r1.5 -r1.6 --- JRMPInvoker.java 2002/01/14 02:00:49 1.5 +++ JRMPInvoker.java 2002/01/14 20:35:59 1.6 @@ -16,6 +16,7 @@ import java.rmi.server.RMIClientSocketFactory; import java.rmi.ServerException; import java.rmi.MarshalledObject; +import java.rmi.server.RemoteStub; import java.util.Date; import javax.naming.Name; @@ -53,7 +54,15 @@ * * @author <a href="mailto:[EMAIL PROTECTED]>Marc Fleury</a> * -* @version $Revision: 1.5 $ +* @version $Revision: 1.6 $ +* +* <p><b>Revisions:</b><br> +* <p><b>2002/01/13: Sacha Labourey</b> +* <ol> +* <li>Make the exported RemoteStub available. For the clustering we need to +* distribute the stub to the other nodes of the cluster. Sending the +* RemoteServer directly fails.</li> +* </ol> */ public class JRMPInvoker @@ -87,6 +96,8 @@ protected int state; protected int id = 0; + protected RemoteStub invokerStub = null; + // Static -------------------------------------------------------- private static TransactionPropagationContextFactory tpcFactory; @@ -139,6 +150,8 @@ public String getStateString() { return states[state]; } + public RemoteStub getStub () { return this.invokerStub; } + public void create() throws Exception { @@ -326,8 +339,8 @@ protected void exportCI() throws Exception { - UnicastRemoteObject.exportObject(this, rmiPort, - clientSocketFactory, serverSocketFactory); + this.invokerStub = (RemoteStub)UnicastRemoteObject.exportObject + (this, rmiPort, clientSocketFactory, serverSocketFactory); } protected void unexportCI() throws Exception
_______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development
