You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@turbine.apache.org by ep...@apache.org on 2003/11/15 17:13:57 UTC
cvs commit: jakarta-turbine-fulcrum/factory/impl/src/java/org/apache/fulcrum/factory DefaultFactoryService.java
epugh 2003/11/15 08:13:57
Added: factory/impl/conf block.xml config.xml
factory/impl/src/test/org/apache/fulcrum/factory
FactoryServiceTest.java
factory/impl/src/java/org/apache/fulcrum/factory/utils
ObjectInputStreamForContext.java
factory/impl maven.xml .cvsignore project.xml
factory/impl/xdocs index.xml tasks.xml navigation.xml
factory/impl/src/test/org/apache/fulcrum/factory/utils
ObjectInputStreamForContextTest.java
factory/impl/src/java/org/apache/fulcrum/factory
DefaultFactoryService.java
Log:
Add impl
Revision Changes Path
1.1 jakarta-turbine-fulcrum/factory/impl/conf/block.xml
Index: block.xml
===================================================================
<container name="test">
<classloader>
<classpath>
<repository>
<resource id="fulcrum:fulcrum-factory-api" version="1.0-alpha-2"/>
</repository>
</classpath>
</classloader>
<component name="factory"
class="org.apache.fulcrum.factory.DefaultFactoryService"/>
</container>
1.1 jakarta-turbine-fulcrum/factory/impl/conf/config.xml
Index: config.xml
===================================================================
<targets>
<target path="/test/factory">
<categories priority="INFO"/>
</target>
</targets>
1.1 jakarta-turbine-fulcrum/factory/impl/src/test/org/apache/fulcrum/factory/FactoryServiceTest.java
Index: FactoryServiceTest.java
===================================================================
package org.apache.fulcrum.factory;
import java.util.ArrayList;
import org.apache.avalon.merlin.unit.AbstractMerlinTestCase;
/**
* @author Eric Pugh
* @author <a href="mailto:mcconnell@apache.org">Stephen McConnell</a>
*
* To change the template for this generated type comment go to
* Window>Preferences>Java>Code Generation>Code and Comments
*/
public class FactoryServiceTest extends AbstractMerlinTestCase
{
private FactoryService factoryService = null;
/**
* Defines the testcase name for JUnit.
*
* @param name the testcase's name.
*/
public FactoryServiceTest(String name)
{
super(name);
}
public static void main(String[] args)
{
junit.textui.TestRunner.run(FactoryServiceTest.class);
}
public void setUp() throws Exception
{
super.setUp();
try
{
factoryService = (FactoryService) this.resolve( "factory" );
}
catch (Throwable e)
{
getLogger().error( "Setup error.", e );
fail(e.getMessage());
}
}
/*
* Class to test for Object getInstance(String)
*/
public void testGetInstanceString() throws Exception
{
Object object = factoryService.getInstance("java.lang.StringBuffer");
assertTrue(object instanceof StringBuffer);
}
/*
* Class to test for Object getInstance(String, ClassLoader)
*/
public void testGetInstanceStringClassLoader() throws Exception
{
Object object = factoryService.getInstance("java.lang.StringBuffer", StringBuffer.class.getClassLoader());
assertTrue(object instanceof StringBuffer);
getLogger().info( "OK" );
}
/*
* Class to test for Object getInstance(String, Object[], String[])
*/
public void testGetInstanceStringObjectArrayStringArray() throws Exception
{
Object params[] = new Object[1];
String sourceValu = "testing";
params[0] = sourceValu;
String signature[] = new String[1];
signature[0] = "java.lang.String";
Object object = factoryService.getInstance("java.lang.StringBuffer", params, signature);
assertTrue(object instanceof StringBuffer);
assertEquals(sourceValu, object.toString());
getLogger().info( "OK" );
}
/*
* Class to test for Object getInstance(String, ClassLoader, Object[], String[])
*/
public void testGetInstanceStringClassLoaderObjectArrayStringArray() throws Exception
{
Object params[] = new Object[1];
String sourceValu = "testing";
params[0] = sourceValu;
String signature[] = new String[1];
signature[0] = "java.lang.String";
Object object =
factoryService.getInstance(
"java.lang.StringBuffer",
StringBuffer.class.getClassLoader(),
params,
signature);
assertTrue(object instanceof StringBuffer);
assertEquals(sourceValu, object.toString());
getLogger().info( "OK" );
}
/**
* @todo Need to run a test where the loader is NOT supported.
* @throws Exception
*/
public void testIsLoaderSupported() throws Exception
{
assertTrue(factoryService.isLoaderSupported("java.lang.String"));
getLogger().info( "OK" );
}
public void testGetSignature() throws Exception
{
Object params[] = new Object[1];
String sourceValu = "testing";
params[0] = sourceValu;
String signature[] = new String[1];
signature[0] = "java.lang.String";
Class[] results = factoryService.getSignature(StringBuffer.class, params, signature);
assertEquals(1, results.length);
assertTrue(results[0].equals(String.class));
Integer sourceValueInteger = new Integer(10);
params[0] = sourceValueInteger;
signature[0] = "java.lang.Integer";
results = factoryService.getSignature(ArrayList.class, params, signature);
assertEquals(1, results.length);
assertTrue("Result:" + results[0].getName(),results[0].equals(Integer.class));
getLogger().info( "OK" );
}
}
1.1 jakarta-turbine-fulcrum/factory/impl/src/java/org/apache/fulcrum/factory/utils/ObjectInputStreamForContext.java
Index: ObjectInputStreamForContext.java
===================================================================
package org.apache.fulcrum.factory.utils;
/* ====================================================================
* The Apache Software License, Version 1.1
*
* Copyright (c) 2001 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 acknowledgment:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowledgment may appear in the software itself,
* if and wherever such third-party acknowledgments normally appear.
*
* 4. The names "Apache" and "Apache Software Foundation" and
* "Apache Turbine" must not be used to endorse or promote products
* derived from this software without prior written permission. For
* written permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache",
* "Apache Turbine", nor may "Apache" appear in their name, without
* prior written permission of the Apache Software Foundation.
*
* 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/>.
*/
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectStreamClass;
import java.io.IOException;
/**
* A deserialization stream for a specific class loader context.
*
* @author <a href="mailto:ilkka.priha@simsoft.fi">Ilkka Priha</a>
* @version $Id: ObjectInputStreamForContext.java,v 1.1 2003/11/15 16:13:57 epugh Exp $
*/
public class ObjectInputStreamForContext extends ObjectInputStream
{
/**
* The class loader of the context.
*/
private ClassLoader classLoader;
// this is to make the proxy happy.
public ObjectInputStreamForContext()
throws IOException
{
}
/**
* Contructs a new object stream for a context.
*
* @param in the serialized input stream.
* @param loader the class loader of the context.
* @throws IOException on errors.
*/
public ObjectInputStreamForContext(InputStream in,
ClassLoader loader)
throws IOException
{
super(in);
classLoader = loader;
}
protected Class resolveClass(ObjectStreamClass v)
throws IOException,
ClassNotFoundException
{
return classLoader == null ?
super.resolveClass(v) : classLoader.loadClass(v.getName());
}
}
1.1 jakarta-turbine-fulcrum/factory/impl/maven.xml
Index: maven.xml
===================================================================
<project default="jar:jar" xmlns:maven="jelly:maven" xmlns:j="jelly:core" xmlns:util="jelly:util">
<preGoal name="java:compile">
<attainGoal name="avalon:meta"/>
</preGoal>
</project>
1.1 jakarta-turbine-fulcrum/factory/impl/.cvsignore
Index: .cvsignore
===================================================================
target
*.log
.classpath
.project
jcoverage.ser
1.1 jakarta-turbine-fulcrum/factory/impl/project.xml
Index: project.xml
===================================================================
<?xml version="1.0"?>
<project>
<extend>${basedir}/../../merlin-project.xml</extend>
<id>fulcrum-factory-impl</id>
<name>Fulcrum Factory Component</name>
<currentVersion>1.0-alpha-2</currentVersion>
<dependencies>
<dependency>
<groupId>fulcrum</groupId>
<artifactId>fulcrum-factory-api</artifactId>
<version>1.0-alpha-2</version>
</dependency>
<!-- Needed only for testing -->
<dependency>
<groupId>merlin</groupId>
<artifactId>merlin-unit</artifactId>
<version>3.2.2-dev</version>
</dependency>
</dependencies>
</project>
1.1 jakarta-turbine-fulcrum/factory/impl/xdocs/index.xml
Index: index.xml
===================================================================
<?xml version="1.0"?>
<document>
<properties>
<title>Factory Component</title>
<author email="epugh@upstate.com">Eric PUgh</author>
</properties>
<body>
<section name="Overview">
<p>
The Factory Service instantiates objects using specified class loaders. If none
is specified, the default one will be used. It is written for use in Turbine but
it can be used in any container compatible with Avalon's ECM container.
</p>
</section>
<section name="Configuration">
<p>
First, here is the role configuration.
</p>
<source>
<![CDATA[
<role
name="org.apache.fulcrum.factory.FactoryService"
shorthand="factory"
default-class="org.apache.fulcrum.factory.DefaultFactoryService"/>
]]>
</source>
<p>
There is configuration values for classloaders, still need to add.
</p>
<source>
<![CDATA[
<factory/>
]]>
</source>
</section>
<section name="Usage">
<p>
</p>
</section>
</body>
</document>
1.1 jakarta-turbine-fulcrum/factory/impl/xdocs/tasks.xml
Index: tasks.xml
===================================================================
<?xml version="1.0"?>
<document>
<properties>
<title>Tasks</title>
<author email="epugh@upstate.com">Eric Pugh</author>
</properties>
<body>
<section name="Tasks">
<p>
Lists of todos and ideas for future versions.
</p>
<subsection name="1.0">
<p>
<ul>
<li>
Need to test using the configuratio values. Currently it just uses the default Classloader.
</li>
<li>
Document using different classloaders.
</li>
</ul>
</p>
</subsection>
</section>
</body>
</document>
1.1 jakarta-turbine-fulcrum/factory/impl/xdocs/navigation.xml
Index: navigation.xml
===================================================================
<?xml version="1.0" encoding="ISO-8859-1"?>
<project
name="localization"
href="http://jakarta.apache.org/turbine/fulcrum/factory/">
<body>
<links>
<item name="Turbine"
href="http://jakarta.apache.org/turbine/"/>
<item name="Fulcrum"
href="http://jakarta.apache.org/turbine/fulcrum/"/>
</links>
<menu name="Overview">
<item name="Main" href="/index.html"/>
<item name="Tasks" href="/tasks.html"/>
</menu>
</body>
</project>
1.1 jakarta-turbine-fulcrum/factory/impl/src/test/org/apache/fulcrum/factory/utils/ObjectInputStreamForContextTest.java
Index: ObjectInputStreamForContextTest.java
===================================================================
/*
* Created on Aug 20, 2003
*
* To change the template for this generated file go to
* Window>Preferences>Java>Code Generation>Code and Comments
*/
package org.apache.fulcrum.factory.utils;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectOutputStream;
import junit.framework.TestCase;
/**
* @author Eric Pugh
*
* To change the template for this generated type comment go to
* Window>Preferences>Java>Code Generation>Code and Comments
*/
public class ObjectInputStreamForContextTest extends TestCase
{
public static void main(String[] args)
{
junit.textui.TestRunner.run(ObjectInputStreamForContextTest.class);
}
/*
* Class to test for void ObjectInputStreamForContext(InputStream, ClassLoader)
*/
public void testObjectInputStreamForContextInputStreamClassLoader() throws Exception
{
Object object = new String("I am testing");
Object object2 = null;
ByteArrayOutputStream bout = new ByteArrayOutputStream();
ObjectOutputStream out = new ObjectOutputStream(bout);
out.writeObject(object);
out.flush();
ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
ObjectInputStreamForContext in = new ObjectInputStreamForContext(bin, String.class.getClassLoader());
object2 = in.readObject();
assertEquals(object.toString(), object2.toString());
assertEquals(object, object2);
}
}
1.1 jakarta-turbine-fulcrum/factory/impl/src/java/org/apache/fulcrum/factory/DefaultFactoryService.java
Index: DefaultFactoryService.java
===================================================================
package org.apache.fulcrum.factory;
/* ====================================================================
* The Apache Software License, Version 1.1
*
* Copyright (c) 2001-2003 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 acknowledgment:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowledgment may appear in the software itself,
* if and wherever such third-party acknowledgments normally appear.
*
* 4. The names "Apache" and "Apache Software Foundation" and
* "Apache Turbine" must not be used to endorse or promote products
* derived from this software without prior written permission. For
* written permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache",
* "Apache Turbine", nor may "Apache" appear in their name, without
* prior written permission of the Apache Software Foundation.
*
* 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/>.
*/
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectOutputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import org.apache.avalon.framework.activity.Initializable;
import org.apache.avalon.framework.configuration.Configurable;
import org.apache.avalon.framework.configuration.Configuration;
import org.apache.avalon.framework.configuration.ConfigurationException;
import org.apache.avalon.framework.logger.AbstractLogEnabled;
import org.apache.fulcrum.factory.utils.ObjectInputStreamForContext;
/**
* The Factory Service instantiates objects using specified
* class loaders. If none is specified, the default one
* will be used.
*
* @author <a href="mailto:epugh@upstate.com">Eric Pugh</a>
* @author <a href="mailto:ilkka.priha@simsoft.fi">Ilkka Priha</a>
* @author <a href="mailto:mcconnell@apache.org">Stephen McConnell</a>
* @version $Id: DefaultFactoryService.java,v 1.1 2003/11/15 16:13:57 epugh Exp $
*
* @avalon.component name="factory" lifestyle="singleton"
* @avalon.service type="org.apache.fulcrum.factory.FactoryService"
*/
public class DefaultFactoryService
extends AbstractLogEnabled
implements FactoryService, Configurable, Initializable
{
protected boolean initialized = false;
//private boolean disposed = false;
/**
* The property specifying a set of additional class loaders.
*/
private static final String CLASS_LOADER = "classloader";
/**
* The property prefix specifying additional object factories.
*/
private static final String OBJECT_FACTORY = "object-factory";
/**
* The name of the default factory.
*/
protected static final String DEFAULT_FACTORY = "default";
/**
* Primitive classes for reflection of constructors.
*/
private static HashMap primitiveClasses;
{
primitiveClasses = new HashMap(8);
primitiveClasses.put(Boolean.TYPE.toString(), Boolean.TYPE);
primitiveClasses.put(Character.TYPE.toString(), Character.TYPE);
primitiveClasses.put(Byte.TYPE.toString(), Byte.TYPE);
primitiveClasses.put(Short.TYPE.toString(), Short.TYPE);
primitiveClasses.put(Integer.TYPE.toString(), Integer.TYPE);
primitiveClasses.put(Long.TYPE.toString(), Long.TYPE);
primitiveClasses.put(Float.TYPE.toString(), Float.TYPE);
primitiveClasses.put(Double.TYPE.toString(), Double.TYPE);
}
/**
* temporary storage of class names between configure and initialize
*/
private String[] loaderNames;
/**
* Additional class loaders.
*/
private ArrayList classLoaders = new ArrayList();
/**
* Customized object factories.
*/
private HashMap objectFactories = new HashMap();
/**
* Gets the class of a primitive type.
*
* @param type a primitive type.
* @return the corresponding class, or null.
*/
protected static Class getPrimitiveClass(String type)
{
return (Class) primitiveClasses.get(type);
}
/**
* Constructs a Factory Service.
*/
public DefaultFactoryService()
{
}
/**
* Gets an instance of a named class.
*
* @param className the name of the class.
* @return the instance.
* @throws FactoryException if instantiation fails.
*/
public Object getInstance(String className) throws FactoryException
{
if (className == null)
{
throw new FactoryException("Missing String className");
}
Factory factory = getFactory(className);
if (factory == null)
{
Class clazz;
try
{
clazz = loadClass(className);
}
catch (ClassNotFoundException x)
{
throw new FactoryException("Instantiation failed for class " + className, x);
}
return getInstance(clazz);
}
else
{
return factory.getInstance();
}
}
/**
* Gets an instance of a named class using a specified class loader.
*
* <p>Class loaders are supported only if the isLoaderSupported
* method returns true. Otherwise the loader parameter is ignored.
*
* @param className the name of the class.
* @param loader the class loader.
* @return the instance.
* @throws FactoryException if instantiation fails.
*/
public Object getInstance(String className, ClassLoader loader) throws FactoryException
{
Factory factory = getFactory(className);
if (factory == null)
{
if (loader != null)
{
Class clazz;
try
{
clazz = loadClass(className, loader);
}
catch (ClassNotFoundException x)
{
throw new FactoryException("Instantiation failed for class " + className, x);
}
return getInstance(clazz);
}
else
{
return getInstance(className);
}
}
else
{
return factory.getInstance(loader);
}
}
/**
* Gets an instance of a named class.
* Parameters for its constructor are given as an array of objects,
* primitive types must be wrapped with a corresponding class.
*
* @param className the name of the class.
* @param params an array containing the parameters of the constructor.
* @param signature an array containing the signature of the constructor.
* @return the instance.
* @throws FactoryException if instantiation fails.
*/
public Object getInstance(String className, Object[] params, String[] signature) throws FactoryException
{
Factory factory = getFactory(className);
if (factory == null)
{
Class clazz;
try
{
clazz = loadClass(className);
}
catch (ClassNotFoundException x)
{
throw new FactoryException("Instantiation failed for class " + className, x);
}
return getInstance(clazz, params, signature);
}
else
{
return factory.getInstance(params, signature);
}
}
/**
* Gets an instance of a named class using a specified class loader.
* Parameters for its constructor are given as an array of objects,
* primitive types must be wrapped with a corresponding class.
*
* <p>Class loaders are supported only if the isLoaderSupported
* method returns true. Otherwise the loader parameter is ignored.
*
* @param className the name of the class.
* @param loader the class loader.
* @param params an array containing the parameters of the constructor.
* @param signature an array containing the signature of the constructor.
* @return the instance.
* @throws FactoryException if instantiation fails.
*/
public Object getInstance(String className, ClassLoader loader, Object[] params, String[] signature)
throws FactoryException
{
Factory factory = getFactory(className);
if (factory == null)
{
if (loader != null)
{
Class clazz;
try
{
clazz = loadClass(className, loader);
}
catch (ClassNotFoundException x)
{
throw new FactoryException("Instantiation failed for class " + className, x);
}
return getInstance(clazz, params, signature);
}
else
{
return getInstance(className, params, signature);
}
}
else
{
return factory.getInstance(loader, params, signature);
}
}
/**
* Tests if specified class loaders are supported for a named class.
*
* @param className the name of the class.
* @return true if class loaders are supported, false otherwise.
* @throws FactoryException if test fails.
*/
public boolean isLoaderSupported(String className) throws FactoryException
{
Factory factory = getFactory(className);
return factory != null ? factory.isLoaderSupported() : true;
}
/**
* Gets an instance of a specified class.
*
* @param clazz the class.
* @return the instance.
* @throws FactoryException if instantiation fails.
*/
public Object getInstance(Class clazz) throws FactoryException
{
try
{
return clazz.newInstance();
}
catch (Exception x)
{
throw new FactoryException("Instantiation failed for " + clazz.getName(), x);
}
}
/**
* Gets an instance of a specified class.
* Parameters for its constructor are given as an array of objects,
* primitive types must be wrapped with a corresponding class.
*
* @param clazz the class.
* @param params an array containing the parameters of the constructor.
* @param signature an array containing the signature of the constructor.
* @return the instance.
* @throws FactoryException if instantiation fails.
*/
protected Object getInstance(Class clazz, Object params[], String signature[]) throws FactoryException
{
/* Try to construct. */
try
{
Class[] sign = getSignature(clazz, params, signature);
return clazz.getConstructor(sign).newInstance(params);
}
catch (Exception x)
{
throw new FactoryException("Instantiation failed for " + clazz.getName(), x);
}
}
/**
* Gets the signature classes for parameters of a method of a class.
*
* @param clazz the class.
* @param params an array containing the parameters of the method.
* @param signature an array containing the signature of the method.
* @return an array of signature classes. Note that in some cases
* objects in the parameter array can be switched to the context
* of a different class loader.
* @throws ClassNotFoundException if any of the classes is not found.
*/
public Class[] getSignature(Class clazz, Object params[], String signature[]) throws ClassNotFoundException
{
if (signature != null)
{
/* We have parameters. */
ClassLoader tempLoader;
ClassLoader loader = clazz.getClassLoader();
Class[] sign = new Class[signature.length];
for (int i = 0; i < signature.length; i++)
{
/* Check primitive types. */
sign[i] = getPrimitiveClass(signature[i]);
if (sign[i] == null)
{
/* Not a primitive one, continue building. */
if (loader != null)
{
/* Use the class loader of the target object. */
sign[i] = loader.loadClass(signature[i]);
tempLoader = sign[i].getClassLoader();
if ((params[i] != null)
&& (tempLoader != null)
&& !tempLoader.equals(params[i].getClass().getClassLoader()))
{
/*
* The class uses a different class loader,
* switch the parameter.
*/
params[i] = switchObjectContext(params[i], loader);
}
}
else
{
/* Use the default class loader. */
sign[i] = loadClass(signature[i]);
}
}
}
return sign;
}
else
{
return null;
}
}
/**
* Switches an object into the context of a different class loader.
*
* @param object an object to switch.
* @param loader the loader of the new context.
*/
protected Object switchObjectContext(Object object, ClassLoader loader)
{
ByteArrayOutputStream bout = new ByteArrayOutputStream();
try
{
ObjectOutputStream out = new ObjectOutputStream(bout);
out.writeObject(object);
out.flush();
}
catch (Exception x)
{
return object;
}
try
{
ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
ObjectInputStreamForContext in = new ObjectInputStreamForContext(bin, loader);
return in.readObject();
}
catch (Exception x)
{
return object;
}
}
/**
* Loads the named class using the default class loader.
*
* @param className the name of the class to load.
* @return the loaded class.
* @throws ClassNotFoundException if the class was not found.
*/
protected Class loadClass(String className) throws ClassNotFoundException
{
ClassLoader loader = this.getClass().getClassLoader();
try
{
return loader != null ? loader.loadClass(className) : Class.forName(className);
}
catch (ClassNotFoundException x)
{
/* Go through additional loaders. */
for (Iterator i = classLoaders.iterator(); i.hasNext();)
{
try
{
return ((ClassLoader) i.next()).loadClass(className);
}
catch (ClassNotFoundException xx)
{
}
}
/* Give up. */
throw x;
}
}
/**
* Loads the named class using a specified class loader.
*
* @param className the name of the class to load.
* @param loader the loader to use.
* @return the loaded class.
* @throws ClassNotFoundException if the class was not found.
*/
protected Class loadClass(String className, ClassLoader loader) throws ClassNotFoundException
{
return loader != null ? loader.loadClass(className) : loadClass(className);
}
/**
* Gets a customized factory for a named class. If no class-specific
* factory is specified but a default factory is, will use the default
* factory.
*
* @param className the name of the class to load.
* @return the factory, or null if not specified and no default.
* @throws FactoryException if instantiation of the factory fails.
*/
protected Factory getFactory(String className) throws FactoryException
{
HashMap factories = objectFactories;
Object factory = factories.get(className);
if (factory == null)
{
//No named factory for this; try the default, if one
//exists.
factory = factories.get(DEFAULT_FACTORY);
}
if (factory != null)
{
if (factory instanceof String)
{
/* Not yet instantiated... */
try
{
factory = (Factory) getInstance((String) factory);
((Factory) factory).init(className);
}
catch (FactoryException x)
{
throw x;
}
catch (ClassCastException x)
{
throw new FactoryException("Incorrect factory " + (String) factory + " for class " + className, x);
}
factories = (HashMap) factories.clone();
factories.put(className, factory);
objectFactories = factories;
}
return (Factory) factory;
}
else
{
return null;
}
}
// ---------------- Avalon Lifecycle Methods ---------------------
/**
* Avalon component lifecycle method
*/
public void configure(Configuration conf) throws ConfigurationException
{
final Configuration[] loaders = conf.getChildren(CLASS_LOADER);
if (loaders != null)
{
loaderNames = new String[loaders.length];
for (int i = 0; i < loaders.length; i++)
{
loaderNames[i] = loaders[i].getValue();
}
}
final Configuration factories = conf.getChild(OBJECT_FACTORY, false);
if (factories != null)
{
Configuration[] nameVal = factories.getChildren();
for (int i = 0; i < nameVal.length; i++)
{
String key = nameVal[i].getName();
String factory = nameVal[i].getValue();
// Store the factory to the table as a string and
// instantiate it by using the service when needed.
objectFactories.put(key, factory);
}
}
}
/**
* Avalon component lifecycle method
* Initializes the service by loading default class loaders
* and customized object factories.
*
* @throws InitializationException if initialization fails.
*/
public void initialize() throws Exception
{
if (loaderNames != null)
{
for (int i = 0; i < loaderNames.length; i++)
{
try
{
classLoaders.add(loadClass(loaderNames[i]).newInstance());
}
catch (Exception x)
{
throw new Exception(
"No such class loader '" + loaderNames[i] + "' for DefaultFactoryService",
x);
}
}
loaderNames = null;
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: turbine-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: turbine-dev-help@jakarta.apache.org