src/org/objectweb/cjdbc/controller/jmx/MBeanServerManager.java

説明を見る。

package org.objectweb.cjdbc.controller.jmx;

import java.util.Iterator;
import java.util.List;

import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.ObjectInstance;
import javax.management.ObjectName;

import org.objectweb.cjdbc.common.i18n.Translate;
import org.objectweb.cjdbc.common.jmx.JmxException;
import org.objectweb.cjdbc.common.log.Trace;

public class MBeanServerManager
{

  static Trace               logger       = Trace
                                              .getLogger("org.objectweb.cjdbc.controller.jmx.MBeanServer");

  private static MBeanServer mbs;
  private static boolean     isJmxEnabled = true;

  public static synchronized MBeanServer getInstance()
  {

    if (!isJmxEnabled)
    {
      return null;
    }

    if (mbs != null)
    {
      return mbs;
    }

    String defaultServerBuilder = System
        .getProperty("javax.management.builder.initial");

    if (!MBeanServerBuilder.class.getName().equals(defaultServerBuilder))
    {
      if (defaultServerBuilder != null)
        logger.error("property javax.management.builder.initial was "
            + defaultServerBuilder);

      logger.debug("setting property javax.management.builder.initial");
      System
          .setProperty("javax.management.builder.initial",
              org.objectweb.cjdbc.controller.jmx.MBeanServerBuilder.class
                  .getName());

    }

    mbs = MBeanServerFactory.createMBeanServer();
    return mbs;
  }

  public static boolean isJmxEnabled()
  {
    return isJmxEnabled;
  }

  public static void setJmxEnabled(boolean isJmxEnabled) throws JmxException
  {
    if (MBeanServerManager.isJmxEnabled != isJmxEnabled && !isJmxEnabled)
    {
      // stop rmi connectors
      List list = RmiConnector.getRmiConnectors();
      for (Iterator it = list.iterator(); it.hasNext();)
      {
        RmiConnector rmi = (RmiConnector) it.next();
        rmi.stop();
      }

      // stop http adaptors
      list = HttpAdaptor.getHttpAdaptors();
      for (Iterator it = list.iterator(); it.hasNext();)
      {
        HttpAdaptor http = (HttpAdaptor) it.next();
        http.stop();
      }
      // Stop mbean server
      MBeanServerFactory.releaseMBeanServer(mbs);
      mbs = null;
    }
    // set jmx enabled to its value
    MBeanServerManager.isJmxEnabled = isJmxEnabled;
  }

  public static ObjectInstance registerMBean(Object object, ObjectName name)
      throws JmxException
  {
    MBeanServer server = getInstance();
    try
    {

      if (server != null)
      {
        logger.debug(Translate.get("jmx.register.mbean", new String[]{
            object.getClass().toString(), name.getCanonicalName()}));

        ObjectInstance objInstance = null;
        if (!server.isRegistered(name))
        {
          objInstance = server.registerMBean(object, name);
        }
        else
        {
          logger.error(Translate.get("jmx.register.mbean.already.exist",
              new String[]{name.getCanonicalName()}));
          objInstance = server.getObjectInstance(name);
        }

        logger.debug(Translate.get("jmx.server.mbean.count", ""
            + server.getMBeanCount()));
        return objInstance;
      }
      return null;
    }
    catch (Exception e)
    {
      logger.error(Translate.get("jmx.register.mbean.failed",
          new String[]{object.getClass().toString(), e.getMessage(),
              e.getClass().toString()}));
      e.printStackTrace();
      e.getCause().printStackTrace();
      throw new JmxException(e);
    }
  }

  public static void unregister(ObjectName name) throws JmxException
  {
    MBeanServer server = getInstance();
    if (server != null)
    {
      try
      {
        // unregister the MBean
        server.unregisterMBean(name);
        logger.debug(Translate.get("jmx.server.mbean.count", ""
            + server.getMBeanCount()));

      }
      catch (Exception e)
      {
        logger.error(Translate.get("jmx.register.mbean.failed", new String[]{
            name.getCanonicalName(), e.getMessage()}));
        throw new JmxException(e);
      }
    }
  }

}

---