Instantiate the RMIClientConnectorImpl.

 
   JMXConnector lConnector = new RMIClientConnectorImpl("server-name" );
                  

Use either instance or its interface JMXConnector or MBeanServer. If you got back an instance you can now work on the remote MBeanServer like it would be a local one.

Look up for the available MBeans, its attributes and operations. You can now retrieve and set the attributes or perform an operation on the remote MBean.

If you register a Notification Listener then stop this instance before terminating the program otherwise the remote MBeanServer will throw an exception when this Notification Listener is called lConnector.stop();

Import the necessary classes

   import com.sun.management.jmx.MBeanServerImpl; 
   import javax.management.MBeanAttributeInfo; 
   import javax.management.MBeanInfo; 
   import javax.management.MBeanOperationInfo; 
   import javax.management.MBeanServer; 
   import javax.management.Notification;
   import javax.management.NotificationFilter; 
   import javax.management.NotificationListener;
   import javax.management.ObjectInstance; 
   import javax.management.ObjectName; 
   import javax.management.ReflectionException; 
   import javax.management.RuntimeErrorException; 
   import javax.management.RuntimeMBeanException; 
   import javax.management.RuntimeOperationsException; 
   import javax.naming.InitialContext; 
   import org.jboss.jmx.interfaces.JMXConnector; 
   import org.jboss.jmx.client.RMIClientConnectorImpl;
               

Instantiate a local MBeanServer (MBeanServerImpl)

   final MBeanServer lLocalServer = new MBeanServerImpl();
               

Load the logger MBean (is needed now because the Connector Factory is a standard JBoss MBean but maybe I should make it to a normal MBean to make it leaner).

   lLocalServer.createMBean(
      "org.jboss.logging.Logger",
      new ObjectName( "DefaultDomain :name=Logger" )
   );
               

Load and start the ConnectorFactory MBean

   final ObjectInstance lFactoryInstance = lLocalServer.createMBean(
      "org.jboss.jmx.client.ConnectorFactoryService",
      new ObjectName( "DefaultDomain:name=ConnectorFactory" )
   );
               

Look for the list of remote Connectors at a given JNDI server (lContext.getEnvironment() returns the actual properties from a given InitialContext).

   Hashtable lProperties = lContext.getEnvironment();
   ConnectorFactoryImpl.JBossConnectorTester lTester = new ConnectorFactoryImpl.JBossConnectorTester();
   Iterator lConnectors = (Iterator) lLocalServer.invoke(
      lFactoryInstance.getObjectName(),
      "getConnectors",
      new Object[] {
         lProperties,
         lTester
      },
      new String[] {
         lProperties.getClass().getName(),
         lTester.getClass().getName()
      }
   );
               

Create a connection to the selected Connector (lConnectorName is an instance returned by the previous retrieved iterator). The ConnectorName contains the information about the server, protocol and the JNDI name of a found JMX Connector.

   
   JMXConnector lConnector = (JMXConnector) lLocalServer.invoke(
      lFactoryInstance.getObjectName(),
      "createConnection",
      new Object[] {
         lConnectorName
      },
      new String[] {
         lConnectorName.getClass().getName()
      }
   );
               

Use the new Connector MBean on the local MBeanServer to get and set the attributes and perform operation on the chosen MBeans on the remote MBeanServer.

   Iterator i = pConnector.queryMBeans( null, null).iterator(); 
   while( i.hasNext() ) {
      MBeanInfo info = pConnector.getMBeanInfo( ( (ObjectInstance) i.next()).getObjectName() );
      MBeanAttributeInfo[] aInfos = info.getAttributes(); 
      ...
      MBeanOperationInfo[] oInfos = info.getOperations(); 
   }
               

Register a Notification Listener on a remote MBean and wait for notification events sent from the remote MBean. The NotSerializableHandback is a helper class to be a serializable proxy for a Handback which maybe is not serializable.

   Iterator i = pConnector.queryMBeans( null, nullitemizedlist).iterator(); 
   int j = 0; 
   while( i.hasNext() ) {
      ObjectInstance lBean = (ObjectInstance) i.next(); 
      try {
         pConnector.addNotificationListener(
            lBean.getObjectName(),
            (NotificationListener) new Listener(),
            (NotificationFilter) null, 
            new NotSerializableHandback( lBean.getObjectName() + "" + j++ ) 
         ); ...
               

   lLocalServer.invoke( lFactoryInstance.getObjectName(),
      "removeConnection",
      new Object[] { 
         lConnectorName
      },
      new String[] {
         lConnectorName.getClass().getName()
      }
   );