src/org/objectweb/cjdbc/common/jmx/notifications/JmxNotification.java

説明を見る。

package org.objectweb.cjdbc.common.jmx.notifications;

import java.io.IOException;
import java.io.StringReader;
import java.io.StringWriter;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.Hashtable;
import java.util.Iterator;

import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.dom4j.io.OutputFormat;
import org.dom4j.io.SAXReader;
import org.dom4j.io.XMLWriter;

public class JmxNotification
{
  private static final String ELT_jmxevent    = "jmxevent";
  private static final String ELT_info        = "info";
  private static final String ELT_source      = "source";
  private static final String ELT_data        = "data";
  private static final String ELT_priority    = "priority";
  private static final String ELT_sequence    = "sequence";
  private static final String ELT_type        = "type";
  private static final String ELT_description = "description";
  private static final String ELT_time        = "time";
  private static final String ELT_controller  = "controller";
  private static final String ELT_mbean       = "mbean";
  private static final String ELT_class       = "class";
  private static final String ELT_server      = "server";
  private static final String ELT_value       = "value";

  private static final String ATT_ip          = "ip";
  private static final String ATT_port        = "port";
  private static final String ATT_name        = "name";

  String                      priority;
  String                      sequence;
  String                      type;
  String                      description;
  String                      controllerName;
  String                      mbeanClass;
  String                      mbeanName;
  String                      mbeanServerIP;
  String                      mbeanServerPort;
  String                      time;
  Hashtable                   dataList;

  public JmxNotification(String priority, String sequence, String type,
      String description, String time, String controllerName,
      String mbeanClass, String mbeanName, String mbeanServerIP,
      String mbeanServerPort, Hashtable dataList)
  {
    this.priority = priority;
    this.sequence = sequence;
    this.type = type;
    this.description = description;
    this.controllerName = controllerName;
    this.mbeanClass = mbeanClass;
    this.mbeanName = mbeanName;
    this.mbeanServerIP = mbeanServerIP;
    this.mbeanServerPort = mbeanServerPort;
    this.time = time;
    this.dataList = dataList;
  }

  public static JmxNotification createNotificationFromXmlString(String xml)
      throws Exception
  {
    StringReader sreader = new StringReader(xml);
    SAXReader reader = new SAXReader();
    Document document = reader.read(sreader);
    return createNotificationFromXml(document);
  }

  public Hashtable getDataList()
  {
    return dataList;
  }
  
  public String getDataValue(String key)
  {
    if(!dataList.containsKey(key))
      return null;
    else
      return(String) ((ArrayList)dataList.get(key)).get(0);
  }

  public String getControllerName()
  {
    return controllerName;
  }
  
  public String getControllerJmxName()
  {
    return getMbeanServerIP()+":"+getMbeanServerPort();
  }

  public void setControllerName(String controllerName)
  {
    this.controllerName = controllerName;
  }

  public String getDescription()
  {
    return description;
  }

  public void setDescription(String description)
  {
    this.description = description;
  }

  public String getMbeanClass()
  {
    return mbeanClass;
  }

  public void setMbeanClass(String mbeanClass)
  {
    this.mbeanClass = mbeanClass;
  }

  public String getMbeanName()
  {
    return mbeanName;
  }

  public void setMbeanName(String mbeanName)
  {
    this.mbeanName = mbeanName;
  }

  public String getMbeanServerIP()
  {
    return mbeanServerIP;
  }

  public void setMbeanServerIP(String mbeanServerIP)
  {
    this.mbeanServerIP = mbeanServerIP;
  }

  public String getMbeanServerPort()
  {
    return mbeanServerPort;
  }

  public void setMbeanServerPort(String mbeanServerPort)
  {
    this.mbeanServerPort = mbeanServerPort;
  }

  public String getPriority()
  {
    return priority;
  }

  public void setPriority(String priority)
  {
    this.priority = priority;
  }

  public String getSequence()
  {
    return sequence;
  }

  public void setSequence(String sequence)
  {
    this.sequence = sequence;
  }

  public String getType()
  {
    return type;
  }

  public void setType(String type)
  {
    this.type = type;
  }

  public static JmxNotification createNotificationFromXml(Document document)
  {
    String priority = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_info + "/" + ELT_priority).getText();
    String sequence = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_info + "/" + ELT_sequence).getText();
    String type = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_info + "/" + ELT_type).getText();
    String description = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_info + "/" + ELT_description).getText();
    String time = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_info + "/" + ELT_time).getText();

    String controllerName = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_source + "/" + ELT_controller)
        .getText();
    String mbeanclass = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_source + "/" + ELT_mbean + "/"
            + ELT_class).getText();
    String mbeanname = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_source + "/" + ELT_mbean).valueOf(
        "@" + ATT_name);
    String serverip = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_source + "/" + ELT_mbean + "/"
            + ELT_server).valueOf("@" + ATT_ip);
    String serverport = document.selectSingleNode(
        "//" + ELT_jmxevent + "/" + ELT_source + "/" + ELT_mbean + "/"
            + ELT_server).valueOf("@" + ATT_port);

    Element root = document.getRootElement();

    Hashtable dataList = new Hashtable();
    for (Iterator i = root.elementIterator(ELT_data); i.hasNext();)
    {
      Element data = (Element) i.next();
      ArrayList list = new ArrayList();
      for (Iterator j = data.elementIterator(ELT_value); j.hasNext();)
      {
        Element value = (Element) j.next();
        list.add(value.getTextTrim());
      }
      dataList.put(data.valueOf("@" + ATT_name), list);
    }
    JmxNotification notif = new JmxNotification(priority, sequence, type,
        description, time, controllerName, mbeanclass, mbeanname, serverip,
        serverport, dataList);
    return notif;
  }

  public Document toXmlDocument()
  {
    Document document = DocumentHelper.createDocument();
    Element root = document.addElement(ELT_jmxevent);

    // Describe info
    Element info = root.addElement(ELT_info);
    info.addElement(ELT_priority).addText(priority);
    info.addElement(ELT_sequence).addText(sequence);
    info.addElement(ELT_type).addText(type);
    info.addElement(ELT_description).addText(description);
    info.addElement(ELT_time).addText(time);

    // Describe source
    Element source = root.addElement(ELT_source);
    source.addElement(ELT_controller).addText(controllerName);

    // Describe mbean
    Element mbean = source.addElement(ELT_mbean).addAttribute(ATT_name,
        mbeanName);
    mbean.addElement(ELT_class).addText(mbeanClass);
    mbean.addElement(ELT_server).addAttribute(ATT_ip, mbeanServerIP)
        .addAttribute(ATT_port, mbeanServerPort);

    // Describe data
    Enumeration keys = dataList.keys();
    while (keys.hasMoreElements())
    {
      String key = (String) keys.nextElement();
      Element data = root.addElement(ELT_data).addAttribute(ATT_name, key);

      Object entry = dataList.get(key);
      if (entry instanceof ArrayList)
      {
        ArrayList list = (ArrayList) entry;
        for (int i = 0; i < list.size(); i++)
          data.addElement(ELT_value).addText((String) list.get(i));
      }
      else if (entry instanceof String[])
      {
        String[] list = (String[]) entry;
        for (int i = 0; i < list.length; i++)
          data.addElement(ELT_value).addText(list[i]);
      }
      else if (entry instanceof String)
      {
        data.addElement(ELT_value).addText((String) entry);
      }
    }
    return document;
  }

  public String toString()
  {
    StringWriter swriter = new StringWriter();
    OutputFormat format = OutputFormat.createCompactFormat();
    XMLWriter writer = new XMLWriter(swriter, format);
    try
    {
      writer.write(toXmlDocument());
    }
    catch (IOException e)
    {
      // ignore
    }
    return swriter.getBuffer().toString();
  }

  public String getTime()
  {
    return time;
  }

  public void setTime(String time)
  {
    this.time = time;
  }

  public void setDataList(Hashtable dataList)
  {
    this.dataList = dataList;
  }
}

---