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

説明を見る。

package org.objectweb.cjdbc.controller.jmx;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;

import javax.management.Attribute;
import javax.management.MBeanServer;
import javax.management.ObjectName;
import javax.management.remote.JMXAuthenticator;

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

public class HttpAdaptor

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

  private String                              hostName;
  private int                                 port;
  //private JMXAuthenticator                    authenticator;
  private SSLConfiguration                    sslConfig;

  private mx4j.tools.adaptor.http.HttpAdaptor adaptor;
  private ObjectName                          objectName;
  private ObjectName                          processorName;

  private static List                         httpAdaptors = new ArrayList();

  public HttpAdaptor(String hostName, int port, JMXAuthenticator authenticator,
      SSLConfiguration sslConfig) throws JmxException
  {
    if (hostName != null)
    {
      this.hostName = hostName;
    }
    else
    {
      try
      {
        this.hostName = InetAddress.getLocalHost().getHostName();
      }
      catch (UnknownHostException ex)
      {
        throw new JmxException(ex);
      }
    }
    this.port = port;
    //this.authenticator = authenticator;
    this.sslConfig = sslConfig;
    addHttpAdaptor(this);
  }

  public void start() throws JmxException
  {
    try
    {

      MBeanServer server = MBeanServerManager.getInstance();
      // register the HTTP adaptor MBean to the agent
      logger.info(Translate.get("jmx.create.http.adaptor", new Object[]{
          hostName, String.valueOf(port)}));
      adaptor = new mx4j.tools.adaptor.http.HttpAdaptor();
      objectName = new ObjectName("Server:name=HttpAdaptor");
      server.registerMBean(adaptor, objectName);
      adaptor.setHost(hostName);
      adaptor.setPort(port);
      // set XSLT processor
      logger.debug(Translate.get("jmx.create.xslt.processor"));
      processorName = new ObjectName("Server:name=XSLTProcessor");
      server.createMBean(mx4j.tools.adaptor.http.XSLTProcessor.class.getName(),
          processorName, null);
      server.setAttribute(objectName, new Attribute("ProcessorName",
          processorName));
      if (this.sslConfig != null)
      {
        //:TODO
        throw new JmxException("ssl for http not implemented");
      }
      adaptor.start();
    }
    catch (Exception e)
    {
      e.printStackTrace();
      throw new JmxException(e);
    }
  }

  public void stop() throws JmxException
  {
    try
    {
      MBeanServer server = MBeanServerManager.getInstance();
      adaptor.stop();
      server.unregisterMBean(objectName);
      server.unregisterMBean(processorName);
    }
    catch (Exception e)
    {
      throw new JmxException(e);
    }
  }

  public static List getHttpAdaptors()
  {
    return httpAdaptors;
  }

  private static synchronized void addHttpAdaptor(HttpAdaptor httpAdaptor)
  {
    httpAdaptors.add(httpAdaptor);
  }
}

---