src/org/objectweb/cjdbc/console/jmx/DataCollectorJmxClient.java

説明を見る。

package org.objectweb.cjdbc.console.jmx;

import javax.management.MBeanException;

import org.objectweb.cjdbc.common.jmx.JmxConstants;
import org.objectweb.cjdbc.common.jmx.JmxException;
import org.objectweb.cjdbc.common.monitor.AbstractDataCollector;

public class DataCollectorJmxClient extends JmxClient
{

  public DataCollectorJmxClient(String host, String port, Object credentials)
      throws JmxException
  {
    super();
    connect(host, port, credentials);
    mbean = JmxConstants.getDataCollectorObjectName();
  }

  public String[][] retrieveControllerLoadData() throws JmxException,
      MBeanException
  {
    return (String[][]) invoke("retrieveControllerLoadData", null);
  }

  public String[][] retrieveVirtualDatabasesData() throws JmxException,
      MBeanException
  {
    return (String[][]) invoke("retrieveVirtualDatabasesData", null, null);
  }

  public String[][] retrieveBackendsData(String virtualDb) throws JmxException,
      MBeanException
  {
    return (String[][]) invoke("retrieveBackendsData", new Object[]{virtualDb});
  }

  public String[][] retrieveCacheData(String virtualDb) throws JmxException,
      MBeanException
  {
    return (String[][]) invoke("retrieveCacheData", new Object[]{virtualDb});

  }

  public String[][] retrieveCacheStatsData(String virtualDb)
      throws JmxException, MBeanException
  {
    return (String[][]) invoke("retrieveCacheStatsData",
        new Object[]{virtualDb});
  }

  public String[][] retrieveClientsData(String virtualDb) throws JmxException,
      MBeanException
  {
    return (String[][]) invoke("retrieveClientsData", new Object[]{virtualDb});
  }

  public String[][] retrieveSQLStats(String virtualDb) throws JmxException,
      MBeanException
  {
    return (String[][]) invoke("retrieveSQLStats", new Object[]{virtualDb});
  }

  public String[][] retrieveSchedulerData(String virtualDb)
      throws JmxException, MBeanException
  {
    return (String[][]) invoke("retrieveSchedulerData", new Object[]{virtualDb});
  }

  private static final String[] RetrieveDataCollectorInstanceParameterData = new String[]{
      "int", "java.lang.String", "java.lang.String"                        };

  public AbstractDataCollector retrieveDataCollectorInstance(int dataType,
      String targetName, String virtualDbName) throws JmxException,
      MBeanException
  {
    return (AbstractDataCollector) invoke("retrieveDataCollectorInstance",
        new Object[]{new Integer(dataType), targetName, virtualDbName},
        RetrieveDataCollectorInstanceParameterData);
  }

  private static final String[] RetrieveDataparameterClass = new String[]{"org.objectweb.cjdbc.common.monitor.AbstractDataCollector"};

  public long retrieveData(AbstractDataCollector collector)
      throws JmxException, MBeanException
  {
    Object o = invoke("retrieveData", new Object[]{collector},
        RetrieveDataparameterClass);
    return Long.parseLong(o.toString());
  }

  public boolean hasVirtualDatabase(String virtualname)
  {
    try
    {
      Boolean check = (Boolean) invoke("hasVirtualDatabase",
          new Object[]{virtualname}, new String[]{"java.lang.String"});
      return (check != null && check.booleanValue() == true) ? true : false;
    }
    catch (Exception e)
    {
      e.printStackTrace();
      return false;
    }
  }
}

---