summaryrefslogtreecommitdiffstats
path: root/sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/deployer/DeployerImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/deployer/DeployerImpl.java')
-rw-r--r--sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/deployer/DeployerImpl.java197
1 files changed, 0 insertions, 197 deletions
diff --git a/sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/deployer/DeployerImpl.java b/sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/deployer/DeployerImpl.java
deleted file mode 100644
index 18f078e4f6..0000000000
--- a/sandbox/rfeng/minicore/src/main/java/org/apache/tuscany/core/deployer/DeployerImpl.java
+++ /dev/null
@@ -1,197 +0,0 @@
-/*
- * 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.core.deployer;
-
-import java.net.URI;
-import java.util.Collection;
-import javax.xml.stream.XMLInputFactory;
-
-import org.osoa.sca.annotations.Reference;
-
-import org.apache.tuscany.api.annotation.Monitor;
-import org.apache.tuscany.core.resolver.AutowireResolver;
-import org.apache.tuscany.spi.builder.Builder;
-import org.apache.tuscany.spi.builder.BuilderException;
-import org.apache.tuscany.spi.builder.BuilderInstantiationException;
-import org.apache.tuscany.spi.builder.BuilderRegistry;
-import org.apache.tuscany.spi.builder.Connector;
-import org.apache.tuscany.spi.component.Component;
-import org.apache.tuscany.spi.component.ComponentManager;
-import org.apache.tuscany.spi.component.RegistrationException;
-import org.apache.tuscany.spi.component.SCAObject;
-import org.apache.tuscany.spi.component.ScopeContainer;
-import org.apache.tuscany.spi.component.ScopeContainerMonitor;
-import org.apache.tuscany.spi.component.ScopeRegistry;
-import org.apache.tuscany.spi.deployer.Deployer;
-import org.apache.tuscany.spi.deployer.DeploymentContext;
-import org.apache.tuscany.spi.loader.Loader;
-import org.apache.tuscany.spi.loader.LoaderException;
-import org.apache.tuscany.spi.loader.LoaderRegistry;
-import org.apache.tuscany.spi.model.ComponentDefinition;
-import org.apache.tuscany.spi.model.Implementation;
-import org.apache.tuscany.spi.model.Scope;
-import org.apache.tuscany.spi.resolver.ResolutionException;
-
-/**
- * Default implementation of Deployer.
- *
- * @version $Rev$ $Date$
- */
-public class DeployerImpl implements Deployer {
- private XMLInputFactory xmlFactory;
- private Loader loader;
- private Builder builder;
- private ScopeContainerMonitor monitor;
- private AutowireResolver resolver;
- private Connector connector;
- private ComponentManager componentManager;
- private ScopeRegistry scopeRegistry;
-
-
- public DeployerImpl(XMLInputFactory xmlFactory,
- Loader loader,
- Builder builder,
- ComponentManager componentManager,
- AutowireResolver resolver,
- Connector connector) {
- this.xmlFactory = xmlFactory;
- this.builder = builder;
- this.loader = loader;
- this.componentManager = componentManager;
- this.resolver = resolver;
- this.connector = connector;
- }
-
- public DeployerImpl() {
- xmlFactory = XMLInputFactory.newInstance("javax.xml.stream.XMLInputFactory", getClass().getClassLoader());
- }
-
- @Reference
- public void setBuilder(BuilderRegistry builder) {
- this.builder = builder;
- }
-
- @Monitor
- public void setMonitor(ScopeContainerMonitor monitor) {
- this.monitor = monitor;
- }
-
- @Reference
- public void setResolver(AutowireResolver resolver) {
- this.resolver = resolver;
- }
-
- @Reference
- public void setConnector(Connector connector) {
- this.connector = connector;
- }
-
- @Reference
- public void setComponentManager(ComponentManager componentManager) {
- this.componentManager = componentManager;
- }
-
- @Reference
- public void setScopeRegistry(ScopeRegistry scopeRegistry) {
- this.scopeRegistry = scopeRegistry;
- }
-
- public <I extends Implementation<?>> Collection<Component> deploy(Component parent,
- ComponentDefinition<I> componentDefinition)
- throws LoaderException, BuilderException, ResolutionException {
- @SuppressWarnings("unchecked")
- ScopeContainer<URI> scopeContainer = scopeRegistry.getScopeContainer(Scope.COMPOSITE);
- URI groupId = componentDefinition.getUri();
- DeploymentContext deploymentContext =
- new RootDeploymentContext(null, null, groupId, xmlFactory, scopeContainer, false);
- // load the model
- load(parent, componentDefinition, deploymentContext);
- // resolve autowires
- resolver.resolve(null, componentDefinition);
- // build runtime artifacts
- build(parent, componentDefinition, deploymentContext);
-/*
- // create a listener so the scope container is shutdown when the top-level composite stops
- RuntimeEventListener listener = new RuntimeEventListener() {
- public void onEvent(Event event) {
- scopeContainer.onEvent(event);
- if (event instanceof ComponentStop) {
- scopeContainer.stop();
- }
- }
- };
- component.addListener(listener);
-*/
-
- Collection<Component> components = deploymentContext.getComponents().values();
- for (Component toRegister : components) {
- try {
- componentManager.register(toRegister);
- } catch (RegistrationException e) {
- throw new BuilderInstantiationException("Error registering component", e);
- }
- }
- connector.connect(componentDefinition);
- return components;
- }
-
- /**
- * Load the componentDefinition type information for the componentDefinition being deployed. For a typical
- * deployment this will result in the SCDL definition being loaded.
- *
- * @param componentDefinition the componentDefinition being deployed
- * @param deploymentContext the current deployment context
- */
- protected <I extends Implementation<?>> void load(Component parent,
- ComponentDefinition<I> componentDefinition,
- DeploymentContext deploymentContext) throws LoaderException {
- loader.loadComponentType(componentDefinition.getImplementation(), deploymentContext);
- }
-
-
- /**
- * Build the runtime context for a loaded componentDefinition.
- *
- * @param parent the context that will be the parent of the new sub-context
- * @param componentDefinition the componentDefinition being deployed
- * @param deploymentContext the current deployment context
- * @return the new runtime context
- */
- protected <I extends Implementation<?>> SCAObject build(Component parent,
- ComponentDefinition<I> componentDefinition,
- DeploymentContext deploymentContext)
- throws BuilderException {
- return builder.build(componentDefinition, deploymentContext);
- }
-
- /**
- * @return the builder
- */
- public Builder getBuilder() {
- return builder;
- }
-
- /**
- * @return the loader
- */
- public Loader getLoader() {
- return loader;
- }
-
-}