/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.tuscany.sca.contribution.resolver; import java.lang.reflect.Constructor; import java.util.HashMap; import java.util.Map; import org.apache.tuscany.sca.contribution.Contribution; import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint; /** * An implementation of an extensible model resolver which delegates to the * proper resolver extension based on the class of the model to resolve. * * @version $Rev: 632499 $ $Date: 2008-02-29 15:59:39 -0800 (Fri, 29 Feb 2008) $ */ public class ExtensibleModelResolver implements ModelResolver { private final ModelResolverExtensionPoint resolvers; private final ModelFactoryExtensionPoint factories; private final Contribution contribution; private final ModelResolver defaultResolver; private final Map, ModelResolver> resolverInstances = new HashMap, ModelResolver>(); private Map map = new HashMap(); /** * Constructs an extensible model resolver * * @param resolvers * @param contribution * @param factories */ @Deprecated public ExtensibleModelResolver(Contribution contribution, ModelResolverExtensionPoint resolvers, ModelFactoryExtensionPoint factories, ModelResolver defaultResolver) { this.contribution = contribution; this.resolvers = resolvers; this.factories = factories; //FIXME Remove this default resolver, this is currently used to resolve policy declarations // but they should be handled by the contribution import/export mechanism instead of this // defaultResolver hack. this.defaultResolver = defaultResolver; } /** * Constructs an extensible model resolver * * @param resolvers * @param contribution * @param factories */ public ExtensibleModelResolver(Contribution contribution, ModelResolverExtensionPoint resolvers, ModelFactoryExtensionPoint factories) { this.contribution = contribution; this.resolvers = resolvers; this.factories = factories; this.defaultResolver = null; } /** * Returns the proper resolver instance based on the interfaces of the model * If one is not available on the registry, instantiate on demand * * @param modelType * @return */ private ModelResolver getModelResolverInstance(Class modelType) { // Look up a model resolver instance for the model class or // each implemented interface Class[] interfaces = modelType.getInterfaces(); Class[] classes = new Class[interfaces.length + 1]; classes[0] = modelType; if (interfaces.length != 0) { System.arraycopy(interfaces, 0, classes, 1, interfaces.length); } for (Class c : classes) { // Look up an existing model resolver instance ModelResolver resolverInstance = resolverInstances.get(c); if (resolverInstance != null) { return resolverInstance; } // We don't have an instance, lookup a model resolver class // and instantiate it Class resolverClass = resolvers.getResolver(c); if (resolverClass != null) { try { Constructor constructor = resolverClass .getConstructor(new Class[] {Contribution.class, ModelFactoryExtensionPoint.class}); if (constructor != null) { // Construct the model resolver instance and cache it resolverInstance = constructor.newInstance(contribution, factories); resolverInstances.put(c, resolverInstance); return resolverInstance; } } catch (Exception e) { throw new IllegalStateException(e); } } } return null; } public void addModel(Object resolved) { ModelResolver resolver = getModelResolverInstance(resolved.getClass()); if (resolver != null) { resolver.addModel(resolved); } else { map.put(resolved, resolved); } } public Object removeModel(Object resolved) { ModelResolver resolver = getModelResolverInstance(resolved.getClass()); if (resolver != null) { return resolver.removeModel(resolved); } else { return map.remove(resolved); } } public T resolveModel(Class modelClass, T unresolved) { ModelResolver resolver = getModelResolverInstance(unresolved.getClass()); if (resolver != null) { return resolver.resolveModel(modelClass, unresolved); } else { //FIXME Remove this default resolver, this is currently used to resolve policy declarations // but they should be handled by the contribution import/export mechanism instead of this // defaultResolver hack. if (defaultResolver != null) { Object resolved = defaultResolver.resolveModel(modelClass, unresolved); if (resolved != null && resolved != unresolved) { return modelClass.cast(resolved); } } Object resolved = map.get(unresolved); if (resolved != null) { // Return the resolved object return modelClass.cast(resolved); } } return unresolved; } }