/* * Copyright (c) 2005 jPOS.org.  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 acknowledgment: *    "This product includes software developed by the jPOS project *    (http://www.jpos.org/)". Alternately, this acknowledgment may *    appear in the software itself, if and wherever such third-party *    acknowledgments normally appear. * * 4. The names "jPOS" and "jPOS.org" must not be used to endorse *    or promote products derived from this software without prior *    written permission. For written permission, please contact *    license@jpos.org. * * 5. Products derived from this software may not be called "jPOS", *    nor may "jPOS" appear in their name, without prior written *    permission of the jPOS project. * * 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 JPOS PROJECT 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 jPOS Project.  For more * information please see <http://www.jpos.org/>. */package org.jpos.q2;import java.io.File;import java.io.FileInputStream;import java.util.List;import java.util.Iterator;import java.util.Properties;import java.util.ResourceBundle;import java.util.MissingResourceException;import java.net.MalformedURLException;import java.lang.reflect.InvocationTargetException;import java.lang.reflect.Method;import java.util.Collection;import javax.management.*;import org.jdom.Element;import org.jpos.core.Configurable;import org.jpos.core.XmlConfigurable;import org.jpos.core.Configuration;import org.jpos.core.ConfigurationException;import org.jpos.core.SimpleConfiguration;import org.jpos.util.Logger;import org.jpos.util.LogSource;/** * @author <a href="mailto:taherkordy@dpi2.dpi.net.ir">Alireza Taherkordi</a> * @author <a href="mailto:apr@cs.com.uy">Alejandro P. Revilla</a> * @version $Revision: 1.14 $ $Date: 2005/05/30 21:04:42 $ */public class QFactory {    ObjectName loaderName;    Q2 q2;    ResourceBundle classMapping;    public QFactory (ObjectName loaderName, Q2 q2) {        super ();        this.loaderName = loaderName;        this.q2  = q2;        classMapping = ResourceBundle.getBundle(this.getClass().getName());    }    public Object instantiate (Q2 server, Element e)         throws ReflectionException,               MBeanException,               InstanceNotFoundException    {        String clazz  = e.getAttributeValue ("class");        if (clazz == null) {            try {                clazz = classMapping.getString (e.getName());            } catch (MissingResourceException ex) {                // no class attribute, no mapping                // let MBeanServer do the yelling            }        }        MBeanServer mserver = server.getMBeanServer();        getExtraPath (server.getLoader (), e);        return mserver.instantiate (clazz, loaderName);    }    public ObjectInstance createQBean (Q2 server, Element e, Object obj)         throws ClassNotFoundException,                InstantiationException,               IllegalAccessException,               MalformedObjectNameException,               MalformedURLException,               InstanceAlreadyExistsException,               MBeanRegistrationException,               InstanceNotFoundException,               MBeanException,               NotCompliantMBeanException,               InvalidAttributeValueException,               ReflectionException,               ConfigurationException    {        String name   = e.getAttributeValue ("name");        if (name == null)            name = e.getName ();        ObjectName objectName = new ObjectName (Q2.QBEAN_NAME + name);        MBeanServer mserver = server.getMBeanServer();        if(mserver.isRegistered(objectName)) {            throw new InstanceAlreadyExistsException (name+" has already been deployed in another file.");        }        ObjectInstance instance = mserver.registerMBean (            obj, objectName         );        try {            setAttribute (mserver, objectName, "Name", name);            String logger = e.getAttributeValue ("logger");            if (logger != null)                setAttribute (mserver, objectName, "Logger", logger);            setAttribute (mserver, objectName, "Server", server);            setAttribute (mserver, objectName, "Persist", e);            configureQBean(mserver,objectName,e);            setConfiguration (obj, e);  // handle legacy (QSP v1) Configurables             if (obj instanceof QBean)                 mserver.invoke (objectName, "init",  null, null);        }        catch (ConfigurationException ce) {            mserver.unregisterMBean(objectName);            throw ce;        }        return instance;    }    public void getExtraPath (QClassLoader loader, Element e) {        Element classpathElement = e.getChild ("classpath");        if (classpathElement != null) {            Iterator iter = classpathElement.getChildren ("url").iterator();            while (iter.hasNext ()) {                Element u = (Element) iter.next ();                try {                    loader.addURL (u.getTextTrim ());                } catch (MalformedURLException ex) {                    q2.getLog().warn (u.getTextTrim(), ex);                }            }        }    }    public void setAttribute         (MBeanServer server, ObjectName objectName,          String attribute, Object value)        throws InstanceNotFoundException,               MBeanException,               InvalidAttributeValueException,               ReflectionException    {        try {            server.setAttribute (                objectName, new Attribute (attribute, value)            );        } catch (AttributeNotFoundException ex) {            // okay to fail        }    }    public void startQBean (Q2 server, ObjectName objectName)        throws ClassNotFoundException,                InstantiationException,               IllegalAccessException,               MalformedObjectNameException,               MalformedURLException,               InstanceAlreadyExistsException,               MBeanRegistrationException,               InstanceNotFoundException,               MBeanException,               NotCompliantMBeanException,               InvalidAttributeValueException,               ReflectionException    {        MBeanServer mserver = server.getMBeanServer();        mserver.invoke (objectName, "start",  null, null);    }    public void destroyQBean (Q2 server, ObjectName objectName, Object obj)        throws ClassNotFoundException,                InstantiationException,               IllegalAccessException,               MalformedObjectNameException,               MalformedURLException,               InstanceAlreadyExistsException,               MBeanRegistrationException,               InstanceNotFoundException,               MBeanException,               NotCompliantMBeanException,               InvalidAttributeValueException,               ReflectionException    {        MBeanServer mserver = server.getMBeanServer();        if (obj instanceof QBean) {