View Javadoc
   package net.sf.panoptes.model.component.jmx;
   
   import java.net.InetAddress;
   import java.net.UnknownHostException;
   import java.util.HashMap;
   import java.util.Iterator;
   import java.util.Set;
   import java.util.Vector;
   
  import javax.management.JMException;
  import javax.management.MBeanInfo;
  import javax.management.ObjectInstance;
  import javax.management.ObjectName;
  import javax.naming.Context;
  
  import net.sf.panoptes.model.component.Component;
  import net.sf.panoptes.model.component.registry.ComponentEntry;
  import net.sf.panoptes.model.component.registry.ComponentName;
  import net.sf.panoptes.model.component.registry.ComponentRegistry;
  import net.sf.panoptes.model.node.ComponentNode;
  import net.sf.panoptes.model.node.NodeDescriptor;
  import net.sf.panoptes.model.node.INode;
  import net.sf.panoptes.model.node.jmx.DomainNode;
  
  import org.jboss.jmx.connector.rmi.RMIConnectorImpl;
  
  /***
   * MBeanServerComponent.java
   * 
   * Wraps a JMX server connector.
   * 
   * @author Dag Liodden
   * @version 0.1
   */
  public class MBeanServerComponent extends Component {
  
  	private ComponentRegistry componentRegistry;
  	private String name;
  	private String host;
  	private int port;
  	private RMIConnectorImpl server = null;
  	private MBeanComponent[] mBeans = new MBeanComponent[0];
  	private HashMap domains = new HashMap();
  
  	private static Vector connections = new Vector();
  
  	/***
  	 * Constructor for MBeanServerComponent.
  	 */
  	public MBeanServerComponent(ComponentRegistry componentRegistry, String name, String host, int port) {
  		this.name = name;
  		this.host = host;
  		this.port = port;
  		this.componentRegistry = componentRegistry;
  		connections.add(this);
  	}
  
  	public static MBeanServerComponent[] listConnections() {
  		return (MBeanServerComponent[]) connections.toArray(new MBeanServerComponent[connections.size()]);
  	}
  
  	public RMIConnectorImpl getConnector() {
  		return server;
  	}
  
  	public void connect() throws JMException, UnknownHostException {
  		String serverName = getHost();
  		if (serverName.equals("localhost")) {
  			serverName = InetAddress.getLocalHost().getHostName();
  		}
  
  		System.setProperty(Context.PROVIDER_URL, "jnp://" + serverName + ":" + port);
  		System.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
  		System.setProperty(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
  
  		/***
  		 * Ripped out of org.jboss.jmx.gui.
  		 * Have no idea why this should be done. :)
  		 */
  		ClassLoader oldCL = Thread.currentThread().getContextClassLoader();
  		try {
  			Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
  			server = new RMIConnectorImpl(RMIConnectorImpl.NOTIFICATION_TYPE_RMI, null, serverName);
  		} catch (Exception e) {
  			throw new JMException(e.getMessage());
  		} finally {
  			Thread.currentThread().setContextClassLoader(oldCL);
  		}
  		refresh();
  	}
  
  	/***
  	 * Returns the host.
  	 * @return String
  	 */
  	public String getHost() {
  		return host;
  	}
  
 	/***
 	 * Returns the name.
 	 * @return String
 	 */
 	public String getName() {
 		return name;
 	}
 
 	/***
 	 * Returns the port.
 	 * @return int
 	 */
 	public int getPort() {
 		return port;
 	}
 
 	/***
 	 * Sets the host.
 	 * @param host The host to set
 	 */
 	public void setHost(String host) {
 		this.host = host;
 	}
 
 	/***
 	 * Sets the name.
 	 * @param name The name to set
 	 */
 	public void setName(String name) {
 		this.name = name;
 	}
 
 	/***
 	 * Sets the port.
 	 * @param port The port to set
 	 */
 	public void setPort(int port) {
 		this.port = port;
 	}
 
 	/***
 	 * Returns the server.
 	 * @return RMIConnectorImpl
 	 */
 	public RMIConnectorImpl getServer() {
 		return server;
 	}
 
 	public void refresh() {
 		try {
 
 			Set s = server.queryMBeans(new ObjectName("*:*"), null);
 
 			Iterator it = s.iterator();
 			domains.clear();
 
 			int i = 0;
 			while (it.hasNext()) {
 				ObjectInstance instance = (ObjectInstance) it.next();
 				ObjectName objectName = instance.getObjectName();
 				/***
 				 * Instanciate domains
 				 */
 				DomainNode domain;
 				String domainName = objectName.getDomain();
 				if (!domains.containsKey(domainName)) {
 					domain = new DomainNode(domainName);
 					domains.put(domainName, domain);
 				} else {
 					domain = (DomainNode) domains.get(domainName);
 				}
 
 				MBeanInfo info = server.getMBeanInfo(objectName);
 				MBeanComponent bean2 = new MBeanComponent(info, this, objectName);
 				String name = objectName.toString();
 				
 				name = name.substring(name.indexOf(':') + 1) + ",domain=" + objectName.getDomain();
 				ComponentName componentName = new ComponentName(ComponentName.DOMAIN_MBEAN, name);
 				componentRegistry.registerComponent(bean2, componentName);
 				domain.addChild(new ComponentNode(componentRegistry, componentName));
 				for (Iterator iter =
 					componentRegistry.findEntries(new ComponentName(ComponentName.DOMAIN_MBEAN + ":*")).iterator();
 					iter.hasNext();
 					) {
 					ComponentEntry entry = (ComponentEntry) iter.next();
 				}
 			}
 		} catch (Exception e) {
 			e.printStackTrace();
 			mBeans = new MBeanComponent[0];
 
 		}
 	}
 
 	public DomainNode[] getDomains() {
 		return (DomainNode[]) domains.values().toArray(new DomainNode[domains.size()]);
 	}
 
 	/***
 	 * @see com.gllt.troodon.console.INode#getChildren()
 	 */
 	public INode[] getChildren() {
 		return getDomains();
 	}
 
 	/***
 	 * @see com.gllt.troodon.console.INode#getIconName()
 	 */
 	public String getIconName() {
 		return INode.ICON_SERVER;
 	}
 
 	/***
 	 * @see com.gllt.troodon.console.INode#getConfigDescriptor()
 	 */
 	public NodeDescriptor getConfigDescriptor() {
 		return new NodeDescriptor(name, "Connection to server " + host + ":" + port);
 	}
 
 	/* (non-Javadoc)
 	 * @see net.sf.panoptes.view.configurator.INode#acceptsChildren()
 	 */
 	public boolean acceptsChildren() {
 		return false;
 	}
 
 }