User: stacycurl
Date: 01/03/29 09:44:10
Modified: src/main/org/jboss/jmx/server RMIConnectorServiceMBean.java
RMIConnectorService.java
Log:
Each JMX agent needs to build a RMIConnector into JNDI, previously there
seem to have been only 1 agent running. I need to run multiple so I need to
have multiple JNDI entries. Hence I've added an additional constructor, also
added an accessor to obtain the JNDI Name.
Revision Changes Path
1.3 +3 -2
jboss/src/main/org/jboss/jmx/server/RMIConnectorServiceMBean.java
Index: RMIConnectorServiceMBean.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/jmx/server/RMIConnectorServiceMBean.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- RMIConnectorServiceMBean.java 2000/12/07 15:44:56 1.2
+++ RMIConnectorServiceMBean.java 2001/03/29 17:44:10 1.3
@@ -8,8 +8,8 @@
package org.jboss.jmx.server;
/**
-* Server side MBean for the RMI connector
-*
+* Server side MBean for the RMI connector
+*
* @author Rickard �berg ([EMAIL PROTECTED])
* @author <A href="mailto:[EMAIL PROTECTED]">Andreas "Mad"
Schaefer</A>
**/
@@ -20,4 +20,5 @@
public static final String OBJECT_NAME = "Connector:name=RMI";
// Public --------------------------------------------------------
+ public String getJNDIName();
}
1.4 +35 -14 jboss/src/main/org/jboss/jmx/server/RMIConnectorService.java
Index: RMIConnectorService.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/jmx/server/RMIConnectorService.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- RMIConnectorService.java 2000/12/07 15:44:56 1.3
+++ RMIConnectorService.java 2001/03/29 17:44:10 1.4
@@ -4,7 +4,7 @@
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
-
+
package org.jboss.jmx.server;
import java.io.File;
@@ -32,8 +32,8 @@
import org.jboss.util.ServiceMBeanSupport;
/**
-* <description>
-*
+* <description>
+*
* @author Rickard �berg ([EMAIL PROTECTED])
* @author <A href="mailto:[EMAIL PROTECTED]">Andreas "Mad"
Schaefer</A>
**/
@@ -47,42 +47,63 @@
public static String JNDI_NAME = "jmx:rmi";
public static String JMX_NAME = "jmx";
public static String PROTOCOL_NAME = "rmi";
-
+
// Attributes ----------------------------------------------------
private MBeanServer server;
private RMIConnectorImpl adaptor;
private String mHost;
-
+ private String mName;
+
// Static --------------------------------------------------------
-
+
// Constructors --------------------------------------------------
-
+ public RMIConnectorService() {
+ mName = null;
+ }
+
+ public RMIConnectorService(
+ String name
+ ) {
+ mName = name;
+ }
+
// Public --------------------------------------------------------
public ObjectName getObjectName(
- MBeanServer server,
+ MBeanServer server,
ObjectName name
) throws javax.management.MalformedObjectNameException {
this.server = server;
return new ObjectName( OBJECT_NAME );
}
-
+
public String getName() {
return "JMX RMI Connector";
}
-
+
+ public String getJNDIName() {
+ if (mName != null)
+ {
+ return JMX_NAME + ":" + mHost + ":" + PROTOCOL_NAME + ":" + mName;
+ }
+ else
+ {
+ return JMX_NAME + ":" + mHost + ":" + PROTOCOL_NAME;
+ }
+ }
+
// Protected -----------------------------------------------------
protected void initService() throws Exception {
mHost = InetAddress.getLocalHost().getHostName();
adaptor = new RMIConnectorImpl( server );
}
-
+
protected void startService() throws Exception {
- new InitialContext().bind( JMX_NAME + ":" + mHost + ":" +
PROTOCOL_NAME, adaptor );
+ new InitialContext().bind( getJNDIName(), adaptor );
}
-
+
protected void stopService() {
try {
- new InitialContext().unbind( JMX_NAME + ":" + mHost + ":" +
PROTOCOL_NAME );
+ new InitialContext().unbind( getJNDIName() );
}
catch( Exception e ) {
log.exception( e );
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
