Create branch for 2.0 beta2 release

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1040693 13f79535-47bb-0310-9956-ffa450edef68

11 files changed, 1531 insertions, 0 deletions

diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/DefaultDeployer.java b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/DefaultDeployer.java
new file mode 100644
index 0000000000..42c7596b15
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/DefaultDeployer.java
@@ -0,0 +1,42 @@
+/*
+ * 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.deployment;
+
+import org.apache.tuscany.sca.core.DefaultExtensionPointRegistry;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.deployment.impl.DeployerImpl;
+
+/**
+ * Default implementation of Deployer 
+ */
+public class DefaultDeployer extends DeployerImpl {
+
+    public DefaultDeployer() {
+        super(new DefaultExtensionPointRegistry());
+    }
+
+    /**
+     * @param registry
+     */
+    public DefaultDeployer(ExtensionPointRegistry registry) {
+        super(registry);
+    }
+
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/Deployer.java b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/Deployer.java
new file mode 100644
index 0000000000..dba21e7197
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/Deployer.java
@@ -0,0 +1,207 @@
+/*
+ * 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.deployment;
+
+import java.io.Reader;
+import java.io.Writer;
+import java.net.URI;
+import java.net.URL;
+import java.util.List;
+import java.util.Map;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.Composite;
+import org.apache.tuscany.sca.assembly.builder.BuilderContext;
+import org.apache.tuscany.sca.assembly.builder.CompositeBuilderException;
+import org.apache.tuscany.sca.contribution.Artifact;
+import org.apache.tuscany.sca.contribution.Contribution;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.LifeCycleListener;
+import org.apache.tuscany.sca.definitions.Definitions;
+import org.apache.tuscany.sca.monitor.Monitor;
+
+/**
+ * A utility that provides system functions to handle Tuscany SCA application deployment
+ */
+public interface Deployer extends LifeCycleListener {
+    /**
+     * Check if Schema Validation for XML Documents is enabled
+     * @return
+     */
+    boolean isSchemaValidationEnabled();
+    
+    /**
+     * Sets Schema Validation for XML Documents flag
+     * @param schemaValidationEnabled
+     */
+    void setSchemaValidationEnabled(boolean schemaValidationEnabled);
+    
+    /**
+     * Attach a deployment composite to the given contribution 
+     * @param contribution The target contribution
+     * @param composite The deployment composite
+     * @param appending A flag to indicate if existing deployable composites in the contribution should be appended or replaced
+     * @return uri of attached composite
+     */
+    String attachDeploymentComposite(Contribution contribution, Composite composite, boolean appending);
+
+    /**
+     * Configure a list of contributions to create a composite representing a view of the domain
+     * @param contributions
+     * @param allContributions
+     * @param bindingBaseURIs
+     * @param monitor
+     * @return
+     * @throws ContributionResolveException
+     * @throws CompositeBuilderException
+     */
+    Composite build(List<Contribution> contributions, List<Contribution> allContributions, Map<QName, List<String>> bindingBaseURIs, Monitor monitor)
+        throws ContributionResolveException, CompositeBuilderException;
+
+    /**
+     * Load an artifact from the given location
+     * @param uri
+     * @param location
+     * @param monitor
+     * @return
+     * @throws ContributionReadException
+     */
+    Artifact loadArtifact(URI uri, URL location, Monitor monitor) throws ContributionReadException;
+
+    /**
+     * Load a contribution from the given location
+     * @param uri
+     * @param location
+     * @param monitor
+     * @return
+     * @throws ContributionReadException
+     */
+    Contribution loadContribution(URI uri, URL location, Monitor monitor) throws ContributionReadException;
+
+    /**
+     * @param <T>
+     * @param uri
+     * @param location
+     * @param monitor
+     * @return
+     * @throws ContributionReadException
+     */
+    <T> T loadDocument(URI uri, URL location, Monitor monitor) throws ContributionReadException;
+
+    /**
+     * @param <T>
+     * @param reader
+     * @param monitor
+     * @return
+     * @throws XMLStreamException
+     * @throws ContributionReadException
+     */
+    <T> T loadXMLDocument(Reader reader, Monitor monitor) throws XMLStreamException, ContributionReadException;
+
+    /**
+     * @param <T>
+     * @param location
+     * @param monitor
+     * @return
+     * @throws XMLStreamException
+     * @throws ContributionReadException
+     */
+    <T> T loadXMLDocument(URL location, Monitor monitor) throws XMLStreamException, ContributionReadException;
+
+    /**
+     * @param <T>
+     * @param reader
+     * @param monitor
+     * @return
+     * @throws ContributionReadException
+     * @throws XMLStreamException
+     */
+    <T> T loadXMLElement(XMLStreamReader reader, Monitor monitor) throws ContributionReadException, XMLStreamException;
+
+    /**
+     * Save the model as XML
+     * @param model
+     * @param writer
+     * @param monitor
+     * @throws XMLStreamException
+     * @throws ContributionWriteException
+     */
+    void saveXMLDocument(Object model, Writer writer, Monitor monitor) throws XMLStreamException,
+        ContributionWriteException;
+
+    /**
+     * Save the model as XML
+     * @param model
+     * @param writer
+     * @param monitor
+     * @throws XMLStreamException
+     * @throws ContributionWriteException
+     */
+    void saveXMLElement(Object model, XMLStreamWriter writer, Monitor monitor) throws XMLStreamException,
+        ContributionWriteException;
+    
+    /**
+     * 
+     * @return
+     */
+    Monitor createMonitor();
+    
+    /**
+     * Create an instance of {@link BuilderContext}
+     * @return
+     */
+    BuilderContext createBuilderContext();
+
+    /**
+     * Create an instance of {@link ProcessorContext}
+     * @return
+     */
+    ProcessorContext createProcessorContext();
+
+    /**
+     * Get the {@link ExtensionPointRegistry}
+     * @return
+     */
+    ExtensionPointRegistry getExtensionPointRegistry();
+    
+    /**
+     * Get the system definitions   
+     */
+    Definitions getSystemDefinitions();  
+
+    /**
+     * Resolve a contributions dependencies
+     * 
+     * @param c
+     * @param allContributions
+     * @param monitor
+     * @throws ContributionResolveException
+     * @throws CompositeBuilderException
+     */
+    void resolve(Contribution c, List<Contribution> dependentContributions, Monitor monitor) throws ContributionResolveException, CompositeBuilderException;
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/impl/Contributions.java b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/impl/Contributions.java
new file mode 100644
index 0000000000..8180ac6465
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/impl/Contributions.java
@@ -0,0 +1,160 @@
+/*
+ * 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.deployment.impl;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Set;
+
+import org.apache.tuscany.sca.assembly.Composite;
+import org.apache.tuscany.sca.assembly.Extension;
+import org.apache.tuscany.sca.contribution.Artifact;
+import org.apache.tuscany.sca.contribution.Contribution;
+import org.apache.tuscany.sca.contribution.Export;
+import org.apache.tuscany.sca.contribution.Import;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+
+/**
+ * A Contribution impl wrapping multiple other contributions
+ * Currently the sole reason for this is so
+ */
+public class Contributions implements Contribution {
+
+    private List<Contribution> contributions = new ArrayList<Contribution>();
+    private String location;
+    private String uri;
+    private Object model;
+    private byte[] contents;
+    private boolean unresolved;
+    private ModelResolver modelResolver;
+    private List<Contribution> dependencies = new ArrayList<Contribution>();
+
+    public Contributions(List<Contribution> contributions) {
+        this.contributions = contributions;
+    }
+
+    public String getLocation() {
+        return location;
+    }
+
+    public Object getModel() {
+        return model;
+    }
+
+    public String getURI() {
+        return uri;
+    }
+
+    public void setLocation(String location) {
+        this.location = location;
+    }
+
+    public void setModel(Object model) {
+        this.model = model;
+    }
+
+    public byte[] getContents() {
+        return contents;
+    }
+
+    public void setContents(byte[] contents) {
+        this.contents = contents;
+    }
+
+    public void setURI(String uri) {
+        this.uri = uri;
+    }
+
+    public boolean isUnresolved() {
+        return unresolved;
+    }
+
+    public void setUnresolved(boolean unresolved) {
+        this.unresolved = unresolved;
+    }
+
+    public List<Contribution> getContributions() {
+        return contributions;
+    }
+
+    public List<Artifact> getArtifacts() {
+        return (List<Artifact>)(Object)contributions;
+    }
+
+    public List<Contribution> getDependencies() {
+        return dependencies;
+    }
+
+    public ClassLoader getClassLoader() {
+        //FIXME Remove later
+        return null;
+    }
+
+    public void setClassLoader(ClassLoader classLoader) {
+        //FIXME Remove later
+    }
+
+    public List<Composite> getDeployables() {
+        List<Composite> deployables = new ArrayList<Composite>();
+        for (Contribution contribution: contributions) {
+            deployables.addAll(contribution.getDeployables());
+        }
+        return deployables;
+    }
+
+    public List<Export> getExports() {
+        List<Export> exports = new ArrayList<Export>();
+        for (Contribution contribution: contributions) {
+            exports.addAll(contribution.getExports());
+        }
+        return exports;
+    }
+
+    public List<Import> getImports() {
+        List<Import> imports = new ArrayList<Import>();
+        for (Contribution contribution: contributions) {
+            imports.addAll(contribution.getImports());
+        }
+        return imports;
+    }
+
+    public ModelResolver getModelResolver() {
+        return modelResolver;
+    }
+
+    public void setModelResolver(ModelResolver modelResolver) {
+        this.modelResolver = modelResolver;
+    }
+
+    public List<Extension> getAttributeExtensions() {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+    public List<Object> getExtensions() {
+        // TODO Auto-generated method stub
+        return null;
+    }
+
+    public Set<String> getTypes() {
+        return Collections.emptySet();
+    }
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/impl/DeployerImpl.java b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/impl/DeployerImpl.java
new file mode 100644
index 0000000000..c3e680bd4d
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/java/org/apache/tuscany/sca/deployment/impl/DeployerImpl.java
@@ -0,0 +1,834 @@
+/*
+ * 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.deployment.impl;
+
+import java.io.Reader;
+import java.io.Writer;
+import java.net.URI;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.logging.Logger;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+
+import org.apache.tuscany.sca.assembly.AssemblyFactory;
+import org.apache.tuscany.sca.assembly.Base;
+import org.apache.tuscany.sca.assembly.Component;
+import org.apache.tuscany.sca.assembly.ComponentReference;
+import org.apache.tuscany.sca.assembly.ComponentService;
+import org.apache.tuscany.sca.assembly.Composite;
+import org.apache.tuscany.sca.assembly.Endpoint;
+import org.apache.tuscany.sca.assembly.EndpointReference;
+import org.apache.tuscany.sca.assembly.Implementation;
+import org.apache.tuscany.sca.assembly.builder.BuilderContext;
+import org.apache.tuscany.sca.assembly.builder.BuilderExtensionPoint;
+import org.apache.tuscany.sca.assembly.builder.CompositeBuilder;
+import org.apache.tuscany.sca.assembly.builder.CompositeBuilderException;
+import org.apache.tuscany.sca.assembly.xsd.Constants;
+import org.apache.tuscany.sca.common.java.io.IOHelper;
+import org.apache.tuscany.sca.common.xml.stax.StAXHelper;
+import org.apache.tuscany.sca.contribution.Artifact;
+import org.apache.tuscany.sca.contribution.Contribution;
+import org.apache.tuscany.sca.contribution.ContributionFactory;
+import org.apache.tuscany.sca.contribution.DefaultImport;
+import org.apache.tuscany.sca.contribution.Export;
+import org.apache.tuscany.sca.contribution.Import;
+import org.apache.tuscany.sca.contribution.java.JavaImport;
+import org.apache.tuscany.sca.contribution.namespace.NamespaceImport;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.contribution.processor.ContributionResolveException;
+import org.apache.tuscany.sca.contribution.processor.ContributionWriteException;
+import org.apache.tuscany.sca.contribution.processor.ExtendedURLArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ExtensibleStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ExtensibleURLArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.ProcessorContext;
+import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessorExtensionPoint;
+import org.apache.tuscany.sca.contribution.processor.ValidatingXMLInputFactory;
+import org.apache.tuscany.sca.contribution.processor.ValidationSchemaExtensionPoint;
+import org.apache.tuscany.sca.contribution.resolver.DefaultImportModelResolver;
+import org.apache.tuscany.sca.contribution.resolver.ExtensibleModelResolver;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolverExtensionPoint;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.FactoryExtensionPoint;
+import org.apache.tuscany.sca.core.ModuleActivatorExtensionPoint;
+import org.apache.tuscany.sca.core.UtilityExtensionPoint;
+import org.apache.tuscany.sca.core.assembly.impl.EndpointRegistryImpl;
+import org.apache.tuscany.sca.definitions.Definitions;
+import org.apache.tuscany.sca.definitions.DefinitionsFactory;
+import org.apache.tuscany.sca.definitions.util.DefinitionsUtil;
+import org.apache.tuscany.sca.definitions.xml.DefinitionsExtensionPoint;
+import org.apache.tuscany.sca.deployment.Deployer;
+import org.apache.tuscany.sca.monitor.Monitor;
+import org.apache.tuscany.sca.monitor.MonitorFactory;
+import org.apache.tuscany.sca.runtime.BaseEndpointRegistry;
+import org.apache.tuscany.sca.runtime.EndpointReferenceBinder;
+import org.apache.tuscany.sca.runtime.EndpointRegistry;
+import org.apache.tuscany.sca.xsd.XSDFactory;
+import org.apache.tuscany.sca.xsd.XSDefinition;
+
+/**
+ * 
+ */
+public class DeployerImpl implements Deployer {
+    protected static final Logger logger = Logger.getLogger(DeployerImpl.class.getName());
+
+    protected boolean inited;
+    protected boolean schemaValidationEnabled;
+    protected StAXHelper staxHelper;
+    protected AssemblyFactory assemblyFactory;
+    protected CompositeBuilder compositeBuilder;
+    protected ContributionFactory contributionFactory;
+    protected ExtendedURLArtifactProcessor<Contribution> contributionProcessor;
+    protected ExtensionPointRegistry registry;
+    protected FactoryExtensionPoint modelFactories;
+    protected ModelResolverExtensionPoint modelResolvers;
+    protected Contribution systemContribution;
+    protected Definitions systemDefinitions;
+    protected ExtensibleURLArtifactProcessor artifactProcessor;
+    protected ExtensibleStAXArtifactProcessor staxProcessor;
+    protected ValidationSchemaExtensionPoint validationSchema;
+    protected EndpointReferenceBinder endpointReferenceBinder;
+
+    protected MonitorFactory monitorFactory;
+
+    protected static final String DEPLOYER_IMPL_VALIDATION_MESSAGES =
+        "org.apache.tuscany.sca.deployment.impl.deployer-impl-validation-messages";
+    
+    public static final QName XSD = new QName("http://www.w3.org/2001/XMLSchema", "schema");
+
+    /**
+     * @param registry
+     */
+    public DeployerImpl(ExtensionPointRegistry registry) {
+        super();
+        this.registry = registry;
+    }
+    
+    public Monitor createMonitor() {
+        init();
+        return monitorFactory.createMonitor();
+    }
+
+    public synchronized void stop() {
+        if (inited) {
+            staxHelper = null;
+            assemblyFactory = null;
+            compositeBuilder = null;
+            contributionFactory = null;
+            contributionProcessor = null;
+            modelFactories = null;
+            modelResolvers = null;
+            systemContribution = null;
+            systemDefinitions = null;
+            artifactProcessor = null;
+            staxProcessor = null;
+            monitorFactory = null;
+            inited = false;
+        }
+    }
+
+    /**
+     * Analyze a contribution and add its dependencies to the given dependency set.
+     */
+    protected void addContributionDependencies(Contribution contribution,
+                                               List<Contribution> contributions,
+                                               List<Contribution> dependencies,
+                                               Set<Contribution> set,
+                                               Monitor monitor) {   
+
+        // Go through the contribution imports
+        for (Import import_ : contribution.getImports()) {
+            boolean resolved = false;
+
+            // Go through all contribution candidates and their exports
+            List<Export> matchingExports = new ArrayList<Export>();
+            for (Contribution dependency : contributions) {
+                if (dependency == contribution) {
+                    // Do not self import
+                    continue;
+                }
+                
+                // When a contribution contains a reference to an artifact from a namespace that 
+                // is declared in an import statement of the contribution, if the SCA artifact 
+                // resolution mechanism is used to resolve the artifact, the SCA runtime MUST resolve 
+                // artifacts from the locations identified by the import statement(s) for the namespace.
+                if (import_ instanceof NamespaceImport) {
+                	NamespaceImport namespaceImport = (NamespaceImport)import_;
+                	if (namespaceImport.getLocation() != null)
+	                	if (!namespaceImport.getLocation().equals(dependency.getURI())) 
+	                		continue;
+                }                
+                if (import_ instanceof JavaImport) {
+                	JavaImport javaImport = (JavaImport)import_;
+                	if (javaImport.getLocation() != null)
+	                	if (!javaImport.getLocation().equals(dependency.getURI())) 
+	                		continue;
+                }
+                
+                for (Export export : dependency.getExports()) {
+
+                    // If an export from a contribution matches the import in hand
+                    // add that contribution to the dependency set
+                    if (import_.match(export)) {
+                        resolved = true;
+                        matchingExports.add(export);
+
+                        if (!set.contains(dependency)) {
+                            set.add(dependency);
+                            dependencies.add(dependency);
+
+                            // Now add the dependencies of that contribution
+                            addContributionDependencies(dependency, contributions, dependencies, set, monitor);
+                        } // end if
+                    } // end if 
+                } // end for
+            } // end for
+
+            if (resolved) {
+                // Initialize the import's model resolver with a delegating model
+                // resolver which will delegate to the matching exports
+                import_.setModelResolver(new DefaultImportModelResolver(matchingExports));
+
+            } else {
+                // Record import resolution issue
+                if (!(import_ instanceof DefaultImport)) {
+                    // Add the (empty) matchingExports List and report a warning
+                    import_.setModelResolver(new DefaultImportModelResolver(matchingExports));
+                    
+                    // push context here as the "stack" in this case is a list of nexted contributions
+                    // through which imports have been chased which may not make much sense to the 
+                    // user so just report the contribution in error
+                    monitor.pushContext("Contribution: " + contribution.getLocation());
+                    Monitor.error(monitor, this, DEPLOYER_IMPL_VALIDATION_MESSAGES, "UnresolvedImport", import_);
+                    monitor.popContext();
+                }
+            } // end if
+        }
+    }
+
+    protected void buildDependencies(Contribution contribution, List<Contribution> contributions, Monitor monitor) {
+        contribution.getDependencies().clear();
+
+        List<Contribution> dependencies = new ArrayList<Contribution>();
+        Set<Contribution> set = new HashSet<Contribution>();
+
+        dependencies.add(contribution);
+        set.add(contribution);
+        addContributionDependencies(contribution, contributions, dependencies, set, monitor);
+
+        Collections.reverse(dependencies);
+
+        contribution.getDependencies().addAll(dependencies);
+    }
+
+    /**
+     * Pre-resolve phase for contributions, to set up handling of imports and exports prior to full resolution
+     * @param contributions - the contributions to preresolve
+     * @param resolver - the ModelResolver to use
+     * @throws ContributionResolveException
+     */
+    protected void contributionsPreresolve(List<Contribution> contributions,
+                                           ModelResolver resolver,
+                                           ProcessorContext context) throws ContributionResolveException {
+
+        for (Contribution contribution : contributions) {
+            contributionProcessor.preResolve(contribution, resolver, context);
+        } // end for
+    } // end method contributionsPreresolve
+
+    public ExtensionPointRegistry getExtensionPointRegistry() {
+        return registry;
+    }
+
+    public void start() {
+        // Defer to the init() method
+    }
+    
+    public synchronized void init() {
+        if (inited) {
+            return;
+        }
+
+        // Enable schema validation only of the logger level is FINE or higher
+        if (isSchemaValidationEnabled()) {
+            ValidationSchemaExtensionPoint schemas = registry.getExtensionPoint(ValidationSchemaExtensionPoint.class);
+            if (schemas != null) {
+                schemas.setEnabled(true);
+            }
+        }
+
+        // Use the runtime-enabled assembly factory
+        modelFactories = registry.getExtensionPoint(FactoryExtensionPoint.class);
+        assemblyFactory = modelFactories.getFactory(AssemblyFactory.class);
+
+        // Create a monitor
+        UtilityExtensionPoint utilities = registry.getExtensionPoint(UtilityExtensionPoint.class);
+        staxHelper = utilities.getUtility(StAXHelper.class);
+
+        monitorFactory = utilities.getUtility(MonitorFactory.class);
+
+        // Initialize the Tuscany module activators
+        // The module activators will be started
+        registry.getExtensionPoint(ModuleActivatorExtensionPoint.class);
+
+        // Get contribution workspace and assembly model factories
+        contributionFactory = modelFactories.getFactory(ContributionFactory.class);
+
+        // Create XML artifact processors
+        staxProcessor = new ExtensibleStAXArtifactProcessor(registry);
+
+        // Create contribution content processor
+        URLArtifactProcessorExtensionPoint docProcessorExtensions =
+            registry.getExtensionPoint(URLArtifactProcessorExtensionPoint.class);
+        artifactProcessor = new ExtensibleURLArtifactProcessor(docProcessorExtensions);
+
+        contributionProcessor =
+            (ExtendedURLArtifactProcessor<Contribution>)docProcessorExtensions.getProcessor(Contribution.class);
+
+        // Get the model resolvers
+        modelResolvers = registry.getExtensionPoint(ModelResolverExtensionPoint.class);
+
+        // Get composite builders
+        BuilderExtensionPoint compositeBuilders = registry.getExtensionPoint(BuilderExtensionPoint.class);
+        compositeBuilder =
+            compositeBuilders.getCompositeBuilder("org.apache.tuscany.sca.assembly.builder.CompositeBuilder");
+
+        // get the validation schema
+        validationSchema = registry.getExtensionPoint(ValidationSchemaExtensionPoint.class);
+        
+        // Get the reference binder
+        endpointReferenceBinder = registry.getExtensionPoint(EndpointReferenceBinder.class);
+            
+        loadSystemContribution(new ProcessorContext(monitorFactory.createMonitor()));
+
+        inited = true;
+    }
+
+    protected void loadSystemContribution(ProcessorContext context) {
+        DefinitionsFactory definitionsFactory = modelFactories.getFactory(DefinitionsFactory.class);
+        systemDefinitions = definitionsFactory.createDefinitions();
+
+        DefinitionsExtensionPoint definitionsExtensionPoint =
+            registry.getExtensionPoint(DefinitionsExtensionPoint.class);
+        
+        Monitor monitor = context.getMonitor();
+        monitor.pushContext("Extension points definitions");
+        try {
+            for (Definitions defs : definitionsExtensionPoint.getDefinitions()) {
+                DefinitionsUtil.aggregate(defs, systemDefinitions, monitor);
+            }
+        } finally {
+            monitor.popContext();
+        }
+
+        // create a system contribution to hold the definitions. The contribution
+        // will be extended later with definitions from application contributions
+        systemContribution = contributionFactory.createContribution();
+        systemContribution.setURI("http://tuscany.apache.org/SystemContribution");
+        systemContribution.setLocation("http://tuscany.apache.org/SystemContribution");
+        ModelResolver modelResolver = new ExtensibleModelResolver(systemContribution, modelResolvers, modelFactories);
+        systemContribution.setModelResolver(modelResolver);
+        systemContribution.setUnresolved(true);
+
+        // create an artifact to represent the system defintions and
+        // add it to the contribution
+        List<Artifact> artifacts = systemContribution.getArtifacts();
+        Artifact artifact = contributionFactory.createArtifact();
+        artifact.setURI("http://tuscany.apache.org/SystemContribution/Definitions");
+        artifact.setLocation("Derived");
+        artifact.setModel(systemDefinitions);
+        artifacts.add(artifact);
+                
+        // now resolve and add the system contribution
+        try {
+            contributionProcessor.resolve(systemContribution, modelResolver, context);
+        } catch (ContributionResolveException e) {
+            throw new IllegalStateException(e);
+        }
+    }
+
+    protected Contribution cloneSystemContribution(Monitor monitor) {
+        init();
+        Contribution contribution = contributionFactory.createContribution();
+        contribution.setURI(systemContribution.getURI());
+        contribution.setLocation(systemContribution.getLocation());
+
+        ModelResolver modelResolver = new ExtensibleModelResolver(contribution, modelResolvers, modelFactories);
+        contribution.setModelResolver(modelResolver);
+        contribution.setUnresolved(true);
+
+        DefinitionsFactory definitionsFactory = modelFactories.getFactory(DefinitionsFactory.class);
+        Definitions definitions = definitionsFactory.createDefinitions();
+        DefinitionsUtil.aggregate(systemDefinitions, definitions, monitor);
+        
+        // create an artifact to represent the system defintions and
+        // add it to the contribution
+        List<Artifact> artifacts = contribution.getArtifacts();
+        Artifact artifact = contributionFactory.createArtifact();
+        artifact.setURI("http://tuscany.apache.org/SystemContribution/Definitions");
+        artifact.setLocation("Derived");
+        artifact.setModel(definitions);
+        artifacts.add(artifact);
+        
+        // create resolver entries to represent the SCA schema. We don't create artifacts
+        // in the contribution as the XSD schema are only actually loaded on demand
+        // so as long as they are in the model resolver we are set. We do it on the clone
+        // so that every copy of the system contribution has the schema
+        ProcessorContext context = new ProcessorContext(monitor);
+        XSDFactory xsdFactory = modelFactories.getFactory(XSDFactory.class);
+        List<String> scaSchemas = validationSchema.getSchemas();
+        for (String scaSchemaLocation : scaSchemas){
+            try {
+                URL scaSchemaURL = new URL(scaSchemaLocation);
+                String namespace = staxHelper.readAttribute(scaSchemaURL, XSD, "targetNamespace");
+
+                // if this is the SCA schema store it in the system contribution
+                if (namespace.equals(Constants.SCA11_TUSCANY_NS)){
+                    
+                    // add the schema to the model resolver under the Tuscany namespace
+                    XSDefinition scaSchema = xsdFactory.createXSDefinition();
+                    scaSchema.setUnresolved(true);
+                    scaSchema.setNamespace(namespace);
+                    scaSchema.setLocation(IOHelper.toURI(scaSchemaURL));
+                    scaSchema.setUnresolved(false); 
+//                    modelResolver.addModel(scaSchema, context);
+                } else if (namespace.equals(Constants.SCA11_NS)) { 
+                    // we know that the SCA schema's are referenced form the Tuscany schemas so 
+                    // register the schema under the SCA namespace too
+                    XSDefinition scaSchema = xsdFactory.createXSDefinition();
+                    scaSchema.setUnresolved(true);
+                    scaSchema.setNamespace(Constants.SCA11_NS);
+                    scaSchema.setLocation(IOHelper.toURI(scaSchemaURL));
+                    scaSchema.setUnresolved(false); 
+                    modelResolver.addModel(scaSchema, context);                  
+                }
+            } catch (Exception ex) {
+                throw new IllegalStateException(ex);
+            }
+        }        
+        
+        return contribution;
+    }
+
+    public String attachDeploymentComposite(Contribution contribution, Composite composite, boolean appending) {
+        init();
+        
+        String compositeArtifactURI = composite.getName().getLocalPart() + ".composite";
+
+        if (appending) {
+            // check its not already there
+            for (Artifact a : contribution.getArtifacts()) {
+                if (compositeArtifactURI.equals(a.getURI())) {
+                    throw new IllegalStateException("artifact '" + compositeArtifactURI + "' already exists in contribution: " + contribution.getURI());
+                }
+            }
+        }
+
+        // Create an artifact for the deployment composite
+        Artifact artifact = contributionFactory.createArtifact();
+        artifact.setURI(compositeArtifactURI);
+
+        artifact.setLocation(compositeArtifactURI);
+        artifact.setModel(composite);
+        artifact.setUnresolved(false);
+        // Add it to the contribution
+        contribution.getArtifacts().add(artifact);
+
+        // Replace the deployable composites with the deployment composites
+        // Clear the deployable composites if it's the first deployment composite
+        if (!appending) {
+            contribution.getDeployables().clear();
+        }
+        contribution.getDeployables().add(composite);
+        return compositeArtifactURI;
+    }
+
+    public Composite build(List<Contribution> contributions, List<Contribution> allContributions, Map<QName, List<String>> bindingMap, Monitor monitor)
+        throws ContributionResolveException, CompositeBuilderException {
+        init();
+        List<Contribution> contributionList = new ArrayList<Contribution>(contributions);
+        
+        Contribution systemContribution = cloneSystemContribution(monitor);
+        Definitions systemDefinitions = systemContribution.getArtifacts().get(0).getModel();
+        // Build an aggregated SCA definitions model. Must be done before we try and
+        // resolve any contributions or composites as they may depend on the full
+        // definitions.xml picture
+
+        // get all definitions.xml artifacts from contributions and aggregate
+        // into the system contribution. In turn add a default import into
+        // each contribution so that, for unresolved items, the resolution
+        // processing will look in the system contribution
+        ProcessorContext context = new ProcessorContext(monitor);
+        for (Contribution contribution : contributionList) {
+            monitor.pushContext("Contribution: " + contribution.getURI());
+            try {
+                // aggregate definitions
+                for (Artifact artifact : contribution.getArtifacts()) {
+                    if (!"META-INF/definitions.xml".equals(artifact.getURI())) {
+                        continue;
+                    }
+                    Object model = artifact.getModel();
+                    // FIXME: Should we check the artifact URI is META-INF/definitions.xml?
+                    if (model instanceof Definitions) {
+                        try {
+                            monitor.pushContext("Definitions: " + artifact.getLocation());
+                            DefinitionsUtil.aggregate((Definitions)model, systemDefinitions, monitor);
+                        } finally {
+                            monitor.popContext();
+                        }                            
+                    }
+                }
+
+                // create a default import and wire it up to the system contribution
+                // model resolver. This is the trick that makes the resolution processing
+                // skip over to the system contribution if resolution is unsuccessful
+                // in the current contribution
+                DefaultImport defaultImport = contributionFactory.createDefaultImport();
+                defaultImport.setModelResolver(systemContribution.getModelResolver());
+                contribution.getImports().add(defaultImport);
+            } finally {
+                monitor.popContext();
+            }
+        }
+
+        ExtensibleModelResolver modelResolver =
+            new ExtensibleModelResolver(new Contributions(contributionList), modelResolvers, modelFactories);
+
+        // now resolve and add the system contribution
+        contributionProcessor.resolve(systemContribution, modelResolver, context);
+        contributionList.add(systemContribution);
+
+        // pre-resolve the contributions
+        contributionsPreresolve(contributionList, modelResolver, context);
+
+        // Build the contribution dependencies
+        Set<Contribution> resolved = new HashSet<Contribution>();
+        
+        for (Contribution contribution : contributionList) {
+            buildDependencies(contribution, allContributions, monitor);
+
+            // Resolve contributions
+            for (Contribution dependency : contribution.getDependencies()) {
+                if (!resolved.contains(dependency)) {
+                    resolved.add(dependency);
+                    contributionProcessor.resolve(dependency, modelResolver, context);
+                }
+            }
+        }
+
+        // Create a top level composite to host our composite
+        // This is temporary to make the activator happy
+        Composite domainComposite = assemblyFactory.createComposite();
+        domainComposite.setName(Composite.DOMAIN_COMPOSITE);
+        domainComposite.setURI(Base.SCA11_NS);
+
+        for (Contribution contribution : contributionList) {
+            for (Composite composite : contribution.getDeployables()) {
+                // Include the node composite in the top-level composite
+                domainComposite.getIncludes().add(composite);
+            }
+        }
+
+        // build the top level composite
+        BuilderContext builderContext = new BuilderContext(systemDefinitions, bindingMap, monitor);
+        compositeBuilder.build(domainComposite, builderContext);
+        // analyzeProblems(monitor);
+   
+        // do build time reference binding
+        buildTimeReferenceBind(domainComposite, builderContext);        
+
+        return domainComposite;
+    }
+    
+    public void resolve(Contribution c, List<Contribution> dependentContributions, Monitor monitor) throws ContributionResolveException, CompositeBuilderException {
+        init();
+        List<Contribution> contributionList = new ArrayList<Contribution>();
+        contributionList.add(c);
+
+        Contribution systemContribution = cloneSystemContribution(monitor);
+        Definitions systemDefinitions = systemContribution.getArtifacts().get(0).getModel();
+        // Build an aggregated SCA definitions model. Must be done before we try and
+        // resolve any contributions or composites as they may depend on the full
+        // definitions.xml picture
+
+        // get all definitions.xml artifacts from contributions and aggregate
+        // into the system contribution. In turn add a default import into
+        // each contribution so that, for unresolved items, the resolution
+        // processing will look in the system contribution
+        ProcessorContext context = new ProcessorContext(monitor);
+        for (Contribution contribution : contributionList) {
+            monitor.pushContext("Contribution: " + contribution.getURI());
+            try {
+                // aggregate definitions
+                for (Artifact artifact : contribution.getArtifacts()) {
+                    if (!"META-INF/definitions.xml".equals(artifact.getURI())) {
+                        continue;
+                    }
+                    Object model = artifact.getModel();
+                    if (model instanceof Definitions) {
+                        try {
+                            monitor.pushContext("Definitions: " + artifact.getLocation());
+                            DefinitionsUtil.aggregate((Definitions)model, systemDefinitions, monitor);
+                        } finally {
+                            monitor.popContext();
+                        }                            
+                    }
+                }
+
+                // create a default import and wire it up to the system contribution
+                // model resolver. This is the trick that makes the resolution processing
+                // skip over to the system contribution if resolution is unsuccessful
+                // in the current contribution
+                DefaultImport defaultImport = contributionFactory.createDefaultImport();
+                defaultImport.setModelResolver(systemContribution.getModelResolver());
+                contribution.getImports().add(defaultImport);
+            } finally {
+                monitor.popContext();
+            }
+        }
+
+        ExtensibleModelResolver modelResolver =
+            new ExtensibleModelResolver(new Contributions(contributionList), modelResolvers, modelFactories);
+
+        // now resolve and add the system contribution
+        contributionProcessor.resolve(systemContribution, modelResolver, context);
+        contributionList.add(systemContribution);
+
+        // pre-resolve the contributions
+        contributionsPreresolve(contributionList, modelResolver, context);
+
+        // Build the contribution dependencies
+        Set<Contribution> resolved = new HashSet<Contribution>();
+        
+        for (Contribution contribution : contributionList) {
+            buildDependencies(contribution, dependentContributions, monitor);
+
+            // Resolve contributions
+            for (Contribution dependency : contribution.getDependencies()) {
+                if (!resolved.contains(dependency)) {
+                    resolved.add(dependency);
+                    contributionProcessor.resolve(dependency, modelResolver, context);
+                }
+            }
+        }
+    }
+
+    public Artifact loadArtifact(URI uri, URL location, Monitor monitor) throws ContributionReadException {
+        init();
+        Artifact artifact = contributionFactory.createArtifact();
+        artifact.setLocation(location.toString());
+        artifact.setURI(uri.toString());
+        URLArtifactProcessorExtensionPoint artifactProcessors =
+            registry.getExtensionPoint(URLArtifactProcessorExtensionPoint.class);
+        ExtensibleURLArtifactProcessor processor = new ExtensibleURLArtifactProcessor(artifactProcessors);
+        Object model = processor.read(null, uri, location, new ProcessorContext(monitor));
+        artifact.setModel(model);
+        return artifact;
+    }
+
+    @SuppressWarnings("unchecked")
+    public <T> T loadDocument(URI uri, URL location, Monitor monitor) throws ContributionReadException {
+        init();
+        Object model = artifactProcessor.read(null, uri, location, new ProcessorContext(monitor));
+        return (T)model;
+    }
+
+    public Object loadXMLDocument(URL document, Monitor monitor) throws XMLStreamException, ContributionReadException {
+        init();
+        XMLStreamReader reader = staxHelper.createXMLStreamReader(document);
+        reader.nextTag();
+        ValidatingXMLInputFactory.setMonitor(reader, monitor);
+        try {
+            return loadXMLElement(reader, monitor);
+        } finally {
+            reader.close();
+        }
+    }
+
+    public void saveXMLDocument(Object model, Writer writer, Monitor monitor) throws XMLStreamException,
+        ContributionWriteException {
+        init();
+        XMLStreamWriter streamWriter = staxHelper.createXMLStreamWriter(writer);
+        staxProcessor.write(model, streamWriter, new ProcessorContext(monitor));
+    }
+
+    public void saveXMLElement(Object model, XMLStreamWriter writer, Monitor monitor) throws XMLStreamException,
+        ContributionWriteException {
+        init();
+        staxProcessor.write(model, writer, new ProcessorContext(monitor));
+    }
+
+    @SuppressWarnings("unchecked")
+    public Object loadXMLElement(XMLStreamReader reader, Monitor monitor) throws ContributionReadException,
+        XMLStreamException {
+        init();
+        return staxProcessor.read(reader, new ProcessorContext(monitor));
+    }
+
+    public Object loadXMLDocument(Reader document, Monitor monitor) throws XMLStreamException, ContributionReadException {
+        init();
+        XMLStreamReader reader = staxHelper.createXMLStreamReader(document);
+        ValidatingXMLInputFactory.setMonitor(reader, monitor);
+        reader.nextTag();
+        try {
+            return loadXMLElement(reader, monitor);
+        } finally {
+            reader.close();
+        }
+    }
+
+    public Contribution loadContribution(URI uri, URL location, Monitor monitor) throws ContributionReadException {
+        init();
+        ProcessorContext context = new ProcessorContext(monitor);
+        // Load the contribution
+        Contribution contribution = contributionProcessor.read(null, uri, location, context);
+        return contribution;
+    }
+
+    public ProcessorContext createProcessorContext() {
+        init();
+        return new ProcessorContext(monitorFactory.createMonitor());
+    }
+
+    public BuilderContext createBuilderContext() {
+        init();
+        return new BuilderContext(monitorFactory.createMonitor());
+    }
+
+    public boolean isSchemaValidationEnabled() {
+        return schemaValidationEnabled;
+    }
+
+    public void setSchemaValidationEnabled(boolean schemaValidationEnabled) {
+        this.schemaValidationEnabled = schemaValidationEnabled;
+    }
+
+    public Definitions getSystemDefinitions() {
+        init();
+        return systemDefinitions;
+    }
+    
+    // The following operations gives references a chance to bind to 
+    // services at deployment time. 
+    
+    private void buildTimeReferenceBind(Composite domainComposite, BuilderContext context){
+        // create temporary local registry for all available local endpoints
+        EndpointRegistry endpointRegistry = new LocalEndpointRegistry(registry);
+        
+        // populate the registry with all the endpoints that are present in the model
+        populateLocalRegistry(domainComposite, endpointRegistry, context);        
+        
+        // match all local services against the endpoint references 
+        // we've just created
+        matchEndpointReferences(domainComposite, endpointRegistry, context); 
+    }
+    
+    private void populateLocalRegistry(Composite composite, EndpointRegistry registry, BuilderContext context){
+        for (Component component : composite.getComponents()) {
+            // recurse for composite implementations
+            Implementation implementation = component.getImplementation();
+            if (implementation instanceof Composite) {
+                populateLocalRegistry((Composite)implementation, registry, context);
+            }
+            
+            // add all endpoints to the local registry
+            for (ComponentService service : component.getServices()) {
+                for (Endpoint endpoint : service.getEndpoints()){
+                    registry.addEndpoint(endpoint);
+                }
+            }
+            
+            // add endpoint references that we want to match to the registry
+            for (ComponentReference reference : component.getReferences()) {
+                for (EndpointReference epr : reference.getEndpointReferences()){
+                    if (epr.getStatus().equals(EndpointReference.Status.WIRED_TARGET_NOT_FOUND)||
+                        epr.getStatus().equals(EndpointReference.Status.WIRED_TARGET_IN_BINDING_URI)){
+                        registry.addEndpointReference(epr);
+                    }
+                }
+            }           
+        }
+    }
+
+    private void matchEndpointReferences(Composite composite, EndpointRegistry registry, BuilderContext builderContext){
+        
+        // look at all the endpoint references and try to match them to 
+        // endpoints
+        for (EndpointReference endpointReference : registry.getEndpointReferences()){
+            endpointReferenceBinder.bindBuildTime(registry, endpointReference, builderContext);
+        }
+    } 
+    
+    // A minimal endpoint registry implementation used to store the Endpoints/EndpointReferences 
+    // for build time local reference resolution. We don't rely on the endpoint registry
+    // factory here as we specifically just want to do simple local resolution
+    class LocalEndpointRegistry extends BaseEndpointRegistry {
+        
+        private List<Endpoint> endpoints = new ArrayList<Endpoint>();
+        
+        public LocalEndpointRegistry(ExtensionPointRegistry registry){
+            super(registry, null, "", "");
+        }
+
+        public void addEndpoint(Endpoint endpoint) {
+            endpoints.add(endpoint);
+            endpointAdded(endpoint);
+        }
+        
+        public void removeEndpoint(Endpoint endpoint) {
+        }
+        
+        public Collection<Endpoint> getEndpoints() {
+            return endpoints;
+        }
+        
+        public Endpoint getEndpoint(String uri) {
+            return null;
+        }
+        
+        public List<Endpoint> findEndpoint(String uri) {
+            List<Endpoint> foundEndpoints = new ArrayList<Endpoint>();
+            for (Endpoint endpoint : endpoints) {
+                if (endpoint.matches(uri)) {
+                    foundEndpoints.add(endpoint);
+                    logger.fine("Found endpoint with matching service  - " + endpoint);
+                }
+                // else the service name doesn't match
+            }
+            return foundEndpoints;
+        }
+        
+        public void start() {
+        }
+
+        public void stop() {
+        }
+    }
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/resources/META-INF/services/org.apache.tuscany.sca.deployment.Deployer b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/resources/META-INF/services/org.apache.tuscany.sca.deployment.Deployer
new file mode 100644
index 0000000000..46e6eba7f7
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/resources/META-INF/services/org.apache.tuscany.sca.deployment.Deployer
@@ -0,0 +1,18 @@
+# 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.

+org.apache.tuscany.sca.deployment.DefaultDeployer

+

diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/resources/org/apache/tuscany/sca/deployment/impl/deployer-impl-validation-messages.properties b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/resources/org/apache/tuscany/sca/deployment/impl/deployer-impl-validation-messages.properties
new file mode 100644
index 0000000000..0c07a3a30f
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/main/resources/org/apache/tuscany/sca/deployment/impl/deployer-impl-validation-messages.properties
@@ -0,0 +1,22 @@
+#
+#
+#    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.
+#
+#
+
+UnresolvedImport = Unresolved import: Import = {0}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/hello/deployer/HelloWorld.java b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/hello/deployer/HelloWorld.java
new file mode 100644
index 0000000000..2480a5e4d9
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/hello/deployer/HelloWorld.java
@@ -0,0 +1,30 @@
+/*
+ * 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 hello.deployer;
+
+import org.oasisopen.sca.annotation.Remotable;
+
+/**
+ * HelloWorld interface
+ */
+@Remotable
+public interface HelloWorld {
+    String hello(String name);
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/hello/deployer/HelloWorldImpl.java b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/hello/deployer/HelloWorldImpl.java
new file mode 100644
index 0000000000..fc81dc2167
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/hello/deployer/HelloWorldImpl.java
@@ -0,0 +1,30 @@
+/*
+ * 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 hello.deployer;
+
+/**
+ * HelloWorldImpl
+ */
+public class HelloWorldImpl implements HelloWorld {
+    public String hello(String name) {
+        System.out.println("Hello: " + name);
+        return "Hello, " + name;
+    }
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/org/apache/tuscany/sca/deployment/impl/DeployerImplTestCase.java b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/org/apache/tuscany/sca/deployment/impl/DeployerImplTestCase.java
new file mode 100644
index 0000000000..e5c0a499a8
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/java/org/apache/tuscany/sca/deployment/impl/DeployerImplTestCase.java
@@ -0,0 +1,135 @@
+/*
+ * 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.deployment.impl;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.io.StringWriter;
+import java.io.Writer;
+import java.net.URISyntaxException;
+import java.net.URL;
+import java.util.Arrays;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.Composite;
+import org.apache.tuscany.sca.contribution.Artifact;
+import org.apache.tuscany.sca.contribution.Contribution;
+import org.apache.tuscany.sca.contribution.processor.ContributionReadException;
+import org.apache.tuscany.sca.core.DefaultExtensionPointRegistry;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.deployment.Deployer;
+import org.apache.tuscany.sca.monitor.Monitor;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+/**
+ * 
+ */
+public class DeployerImplTestCase {
+    private static ExtensionPointRegistry registry;
+    private static Deployer deployer;
+
+    private static URL contributionURL;
+    private static URL compositeURL;
+
+    /**
+     * @throws java.lang.Exception
+     */
+    @BeforeClass
+    public static void setUpBeforeClass() throws Exception {
+        compositeURL = DeployerImplTestCase.class.getResource("HelloWorld.composite");
+        contributionURL = new URL(compositeURL, "../");
+        registry = new DefaultExtensionPointRegistry();
+        deployer = new DeployerImpl(registry);
+        deployer.start();
+    }
+
+    /**
+     * @throws java.lang.Exception
+     */
+    @AfterClass
+    public static void tearDownAfterClass() throws Exception {
+        deployer.stop();
+    }
+
+    /**
+     * Test method for {@link org.apache.tuscany.sca.deployment.impl.DeployerImpl#build(java.util.List, java.util.Map, org.apache.tuscany.sca.monitor.Monitor)}.
+     */
+    @Test
+    public void testBuild() throws Exception {
+        Monitor monitor = deployer.createMonitor();
+        Contribution contribution = deployer.loadContribution(contributionURL.toURI(), contributionURL, monitor);
+        Composite composite = deployer.build(Arrays.asList(contribution), Arrays.asList(contribution), null, monitor);
+        assertTrue(composite != null);
+    }
+
+    /**
+     * Test method for {@link org.apache.tuscany.sca.deployment.impl.DeployerImpl#loadArtifact(java.net.URI, java.net.URL, org.apache.tuscany.sca.monitor.Monitor)}.
+     */
+    @Test
+    public void testLoadArtifact() throws Exception {
+        Monitor monitor = deployer.createMonitor();
+        Artifact artifact = deployer.loadArtifact(compositeURL.toURI(), compositeURL, monitor);
+        assertTrue(artifact.getModel() instanceof Composite);
+        Composite composite = artifact.getModel();
+        assertEquals(composite.getName(), new QName("http://sample/composite", "HelloWorld1"));
+    }
+
+    /**
+     * Test method for {@link org.apache.tuscany.sca.deployment.impl.DeployerImpl#loadDocument(java.net.URI, java.net.URL, org.apache.tuscany.sca.monitor.Monitor)}.
+     */
+    @Test
+    public void testLoadDocument() throws Exception {
+        Monitor monitor = deployer.createMonitor();
+        Composite composite = deployer.loadDocument(compositeURL.toURI(), compositeURL, monitor);
+        assertEquals(composite.getName(), new QName("http://sample/composite", "HelloWorld1"));
+    }
+
+    /**
+     * Test method for {@link org.apache.tuscany.sca.deployment.impl.DeployerImpl#loadXMLDocument(java.net.URL, org.apache.tuscany.sca.monitor.Monitor)}.
+     */
+    @Test
+    public void testLoadXMLDocumentURLMonitor() throws Exception {
+        Monitor monitor = deployer.createMonitor();
+        Composite composite = deployer.loadXMLDocument(compositeURL, monitor);
+        assertEquals(composite.getName(), new QName("http://sample/composite", "HelloWorld1"));
+        Writer sw = new StringWriter();
+        deployer.saveXMLDocument(composite, sw, monitor);
+        assertTrue(sw.toString() != null);
+    }
+
+    /**
+     * Test method for {@link org.apache.tuscany.sca.deployment.impl.DeployerImpl#loadContribution(java.net.URI, java.net.URL, org.apache.tuscany.sca.monitor.Monitor)}.
+     * @throws URISyntaxException 
+     * @throws ContributionReadException 
+     */
+    @Test
+    public void testLoadContribution() throws Exception {
+        Monitor monitor = deployer.createMonitor();
+        Contribution contribution = deployer.loadContribution(contributionURL.toURI(), contributionURL, monitor);
+        Composite composite = contribution.getDeployables().get(0);
+        assertEquals(composite.getName(), new QName("http://sample/composite", "HelloWorld1"));
+        assertTrue(contribution.getArtifacts().size() >= 2);
+    }
+
+}
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/resources/META-INF/sca-contribution.xml b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/resources/META-INF/sca-contribution.xml
new file mode 100644
index 0000000000..5dc99a46a7
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/resources/META-INF/sca-contribution.xml
@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+* 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.    
+-->
+
+<contribution xmlns="http://docs.oasis-open.org/ns/opencsa/sca/200912" 
+              xmlns:sc="http://sample/composite">
+    <deployable composite="sc:HelloWorld1" />
+</contribution>
diff --git a/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/resources/org/apache/tuscany/sca/deployment/impl/HelloWorld.composite b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/resources/org/apache/tuscany/sca/deployment/impl/HelloWorld.composite
new file mode 100644
index 0000000000..23555ea491
--- /dev/null
+++ b/sca-java-2.x/branches/2.0-Beta2/modules/deployment/src/test/resources/org/apache/tuscany/sca/deployment/impl/HelloWorld.composite
@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+    * 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.    
+-->
+<composite xmlns="http://docs.oasis-open.org/ns/opencsa/sca/200912"
+    xmlns:tuscany="http://tuscany.apache.org/xmlns/sca/1.1"
+	targetNamespace="http://sample/composite"
+	name="HelloWorld1">
+
+    <component name="HelloWorld1">
+        <implementation.java class="hello.deployer.HelloWorldImpl"/>
+    </component>
+
+</composite>