costin 2002/11/05 11:13:42 Added: modeler/src/java/org/apache/commons/modeler JndiJmx.java Log: A better solution to intercept the attribute setting and instances. Use the standard notification - will work for any mbean supporting the attribute change notification. The goal is to persist the config data that is changed via JMX - without saving all the attributes. Jndi is used because (IMO) it is the natural API for that. Revision Changes Path 1.1 jakarta-commons/modeler/src/java/org/apache/commons/modeler/JndiJmx.java Index: JndiJmx.java =================================================================== /* * ==================================================================== * * The Apache Software License, Version 1.1 * * Copyright (c) 2001-2002 The Apache Software Foundation. All rights * reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in * the documentation and/or other materials provided with the * distribution. * * 3. The end-user documentation included with the redistribution, if * any, must include the following acknowlegement: * "This product includes software developed by the * Apache Software Foundation (http://www.apache.org/)." * Alternately, this acknowlegement may appear in the software itself, * if and wherever such third-party acknowlegements normally appear. * * 4. The names "The Jakarta Project", "Commons", and "Apache Software * Foundation" must not be used to endorse or promote products derived * from this software without prior written permission. For written * permission, please contact [EMAIL PROTECTED] * * 5. Products derived from this software may not be called "Apache" * nor may "Apache" appear in their names without prior written * permission of the Apache Group. * * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE * DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. * ==================================================================== * * This software consists of voluntary contributions made by many * individuals on behalf of the Apache Software Foundation. For more * information on the Apache Software Foundation, please see * <http://www.apache.org/>. * * [Additional notices, if required by prior licensing conditions] * */ package org.apache.commons.modeler; import java.io.*; import java.net.URL; import java.lang.reflect.InvocationTargetException; import java.util.*; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; // Depends on JNDI - if a DirContext is provided we'll push info into it. import javax.naming.*; import javax.naming.directory.*; import javax.management.*; // EXPERIMENTAL. It may fit better in tomcat jndi impl. /** * * Link between JNDI and JMX. JNDI can be used for persistence ( it is * an API for storing hierarchical data and a perfect fit for that ), as * well as an alternate view of the MBean registry. * * If this component is enabled, all MBeans will be registered in JNDI, and * all attributes that are set via JMX can be stored in a DirContext. * * @author Costin Manolache */ public class JndiJmx implements NotificationListener { private static Log log= LogFactory.getLog(JndiJmx.class); protected Context componentContext; protected Context descriptorContext; protected Context configContext; MBeanServer mserver; /** * Protected constructor to require use of the factory create method. */ public JndiJmx() { } /** If a JNDI context is set, all components * will be registered in the context. * * @param ctx */ public void setComponentContext(Context ctx) { this.componentContext= ctx; } /** JNDI context for component descriptors ( metadata ). * * @param ctx */ public void setDescriptorContext(Context ctx) { this.descriptorContext= ctx; } /** JNDI context where attributes will be stored for persistence * */ public void setConfigContext( Context ctx ) { this.configContext= ctx; } // -------------------- Registration/unregistration -------------------- // temp - will only set in the jndi contexts Hashtable attributes=new Hashtable(); Hashtable instances=new Hashtable(); public void handleNotification(Notification notification, Object handback) { // register/unregister mbeans in jndi if( notification instanceof MBeanServerNotification ) { MBeanServerNotification msnot=(MBeanServerNotification)notification; ObjectName oname=msnot.getMBeanName(); if( "jmx.mbean.created".equalsIgnoreCase( notification.getType() )) { try { Object mbean=mserver.getObjectInstance(oname); if( log.isDebugEnabled() ) log.debug( "MBean created " + oname + " " + mbean); // XXX add filter support if( mbean instanceof NotificationBroadcaster ) { // register for attribute changes NotificationBroadcaster nb=(NotificationBroadcaster)mbean; nb.addNotificationListener(this, null, null); if( log.isDebugEnabled() ) log.debug( "Add attribute change listener"); } instances.put( oname.toString(), mbean ); } catch( InstanceNotFoundException ex ) { log.error( "Instance not found for the created object", ex ); } } if( "jmx.mbean.deleted".equalsIgnoreCase( notification.getType() )) { instances.remove(oname.toString()); } } // set attributes in jndi // if( "jmx.attribute.changed".equals( notification.getType() )) { if( notification instanceof AttributeChangeNotification) { AttributeChangeNotification anotif=(AttributeChangeNotification)notification; String name=anotif.getAttributeName(); Object value=anotif.getNewValue(); Object source=anotif.getSource(); log.debug( "Attribute change notification " + name + " " + value + " " + source ); } } public void init() throws Exception { MBeanServer mserver=(MBeanServer)Registry.getRegistry().getMBeanServer(); ObjectName delegate=new ObjectName("JMImplementation:type=MBeanServerDelegate"); // we'll know of all registered beans mserver.addNotificationListener(delegate, this, null, null ); } }
-- To unsubscribe, e-mail: <mailto:commons-dev-unsubscribe@;jakarta.apache.org> For additional commands, e-mail: <mailto:commons-dev-help@;jakarta.apache.org>
