User: slaboure
Date: 01/09/20 16:29:27
Modified: src/main/org/jboss/ha/jndi HANamingService.java
Log:
Tightend integration of HANamingService with the new HARMIServerImpl.
Revision Changes Path
1.5 +7 -5 jbossmx/src/main/org/jboss/ha/jndi/HANamingService.java
Index: HANamingService.java
===================================================================
RCS file: /cvsroot/jboss/jbossmx/src/main/org/jboss/ha/jndi/HANamingService.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- HANamingService.java 2001/09/20 07:57:52 1.4
+++ HANamingService.java 2001/09/20 23:29:27 1.5
@@ -61,7 +61,7 @@
@author oberg
@author [EMAIL PROTECTED]
- @version $Revision: 1.4 $
+ @version $Revision: 1.5 $
*/
public class HANamingService extends ServiceMBeanSupport implements Runnable,
HANamingServiceMBean, DistributedReplicantManager.ReplicantListener
{
@@ -295,17 +295,19 @@
{
log.info("Starting HAJNDI server");
+ this.rmiserver = new HARMIServerImpl(partition, "HAJNDI", theServer);
+ this.haclient = new HARMIClient(new Object[0], new RoundRobin());
+
log.info("Register with replicantManager as listener for HAJNDI replicants");
replicantManager.registerListener("HAJNDI", this);
+ replicantManager.add ("HAJNDI", this.rmiserver.getStub ());
log.info("create proxy");
- this.haclient = new HARMIClient(new Object[0], new RoundRobin());
+
this.hastub = (Naming)Proxy.newProxyInstance(
Naming.class.getClassLoader(),
new Class[] { Naming.class },
this.haclient);
- this.rmiserver = new HARMIServerImpl(partition, "HAJNDI", theServer);
-
log.info("Start listener");
try
{
@@ -330,7 +332,7 @@
log.info("Stopping");
// Unexport server
- UnicastRemoteObject.unexportObject(theServer, false);
+ this.rmiserver.destroy ();
// Stop listener
ServerSocket s = serverSocket;
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
