Access JMX MBean information through RMI

This is a follow up to my earlier post.

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import javax.management.remote.JMXServiceURL;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.*;
import javax.management.openmbean.CompositeData;
import java.lang.management.ManagementFactory;
import java.net.MalformedURLException;
import java.io.IOException;
import java.util.Set;

public class JmxReport {
private static final Log log = LogFactory.getLog(JmxReport.class);

public static void logJmxInfo() {
   // Operating System MXBean
   log.info("Operating system architecture : " + ManagementFactory.getOperatingSystemMXBean().getArch());
   log.info("Available processors          : " + ManagementFactory.getOperatingSystemMXBean().getAvailableProcessors());
   log.info("Operating system name         : " + ManagementFactory.getOperatingSystemMXBean().getName());
   log.info("System load average           : " + ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage());
   log.info("Operating system version      : " + ManagementFactory.getOperatingSystemMXBean().getVersion());

   // Memory MXBean
   log.info("Heap memory usage             : " + ManagementFactory.getMemoryMXBean().getHeapMemoryUsage().toString());
   log.info("Non-heap memory usage         : " + ManagementFactory.getMemoryMXBean().getNonHeapMemoryUsage().toString());

   // Class loading MXBean
   log.info("Loaded class count            : " + ManagementFactory.getClassLoadingMXBean().getLoadedClassCount());
   log.info("Total loaded class count      : " + ManagementFactory.getClassLoadingMXBean().getTotalLoadedClassCount());
   log.info("Unloaded class count          : " + ManagementFactory.getClassLoadingMXBean().getUnloadedClassCount());
}

public static void getJmxStatisticsViaRmi() {
   try {
       String jmxAgentName = "org.apache.synapse";
       MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();

       JMXConnector c = JMXConnectorFactory.newJMXConnector(createConnectionURL("heshan-laptop", 1099), null/*map*/);
       c.connect();
       Object o = c.getMBeanServerConnection().getAttribute(new ObjectName("java.lang:type=Memory"), "HeapMemoryUsage");
       CompositeData cd = (CompositeData) o;
       System.out.println(cd.get("committed"));

       Object object2 = c.getMBeanServerConnection().getObjectInstance(new ObjectName("org.apache.synapse:Type=Transport,ConnectorName=nio-http-listener"));
       Object lastResetTime = c.getMBeanServerConnection().getAttribute(new ObjectName("org.apache.synapse:Type=Transport,ConnectorName=nio-http-listener"), "LastResetTime");
       System.out.println("lastResetTime : " + lastResetTime.toString());

       ObjectName objName = new ObjectName("org.apache.synapse:Type=Transport,ConnectorName=nio-http-listener");
       Set set2 = mbs.queryNames(objName, null);
       for (Object o2 : set2) {
           log.info("  :: " + o2.toString());
       }
   } catch (MalformedObjectNameException e) {
       e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
   } catch (InstanceNotFoundException e) {
       e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
   } catch (MalformedURLException e) {
       e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
   } catch (IOException e) {
       e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
   } catch (ReflectionException e) {
       e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
   } catch (AttributeNotFoundException e) {
       e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
   } catch (MBeanException e) {
       e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
   }
}

private static JMXServiceURL createConnectionURL(String host, int port) throws MalformedURLException {
   JMXServiceURL serviceURL = new JMXServiceURL("rmi", "", 0, "/jndi/rmi://" + host + ":" + port + "/synapse");
/* To monitor JMX info of Carbon Platform need to enable jmx port @ carbon.xml
   The link is service:jmx:rmi:///jndi/rmi://10.100.1.143:9999/server 
*/
   return serviceURL;
}

public static void main(String args[]) {
   getJmxStatisticsViaRmi();
}
}