diff options
author | lresende <lresende@13f79535-47bb-0310-9956-ffa450edef68> | 2009-11-13 01:42:27 +0000 |
---|---|---|
committer | lresende <lresende@13f79535-47bb-0310-9956-ffa450edef68> | 2009-11-13 01:42:27 +0000 |
commit | 3c7c4a749baafcf375f4785a7668d3a25c9063e3 (patch) | |
tree | a66b8b031c5dc6c7744f44b44b6bcd371bd0b8df /branches/sca-java-1.x/modules/workspace-manager/src/main | |
parent | eb03ff672236cddf65533f39b83ddd5e2984a2bb (diff) |
Moving 1.x trunk
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@835700 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'branches/sca-java-1.x/modules/workspace-manager/src/main')
2 files changed, 0 insertions, 296 deletions
diff --git a/branches/sca-java-1.x/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/WorkspaceManager.java b/branches/sca-java-1.x/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/WorkspaceManager.java deleted file mode 100644 index 0ea82f8e86..0000000000 --- a/branches/sca-java-1.x/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/WorkspaceManager.java +++ /dev/null @@ -1,106 +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.sca.workspace.manager; - -import org.apache.tuscany.sca.contribution.Contribution; -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.workspace.Workspace; -import org.apache.tuscany.sca.workspace.manager.impl.WorkspaceManagerImpl; -import org.osoa.sca.ServiceRuntimeException; - -/** - * This workspace manager class provides an SPI for firing up the Tuscany runtime - * and for providing access to the Tuscany ExtensionPointRegsitry. With a reference to the - * registry you can add new extension points programmatically before starting the runtime. - * Once the runtime is started you can read contributions, create a workspace, populate it - * and then resolve it. - * - * A workspace is a collection of contributions. A workspace populated - * with one or more contribution models can be resolved to ensure - * that all referenced artifacts are located. When more than one contribution - * model is present resolution takes into account the import and export relationships - * between contributions. - */ -public abstract class WorkspaceManager { - - /** - * Get a new instance of the WorkspaceManager. Each call will create a - * distinct instance. - * - * @return workspace manager - */ - public static WorkspaceManager newInstance() throws ServiceRuntimeException{ - try { - // replace with service discovery lookup? - return new WorkspaceManagerImpl(); - } catch(Exception ex){ - throw new ServiceRuntimeException(ex); - } - } - - /** - * If you want to add new extensions to the extension point - * registry and have the runtime take notice of them you need - * to do this before calling start - */ - public abstract ExtensionPointRegistry getRegistry(); - - /** - * Starting the runtime creates the extensible model processors and - * resolvers based on the extension points currently found in the - * extension point registry. - */ - public abstract void start() throws ServiceRuntimeException; - - /** - * Remove any resources being held by the runtime - */ - public abstract void stop() throws ServiceRuntimeException; - - /** - * Create an empty workspace - * - * @return workspace - */ - public abstract Workspace createWorkspace() throws ServiceRuntimeException; - - /** - * Create a contribution model by reading from the specified location URL - * - * @param name the URI that's given to the contribution - * @param location the URL of the contribution to be read - */ - public abstract Contribution readContribution(String name, String location) throws ServiceRuntimeException; - - /** - * Add a contribution to a workspace - * - * @param workspace the workspace to be extended - * @param contribution the contribution to be added - */ - public abstract void addContributionToWorkspace(Workspace workspace, Contribution contribution) throws ServiceRuntimeException; - - /** - * Resolve all of the contributions in the workspace - * - * @param workspace - */ - public abstract void resolveWorkspace(Workspace workspace) throws ServiceRuntimeException; -} diff --git a/branches/sca-java-1.x/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/impl/WorkspaceManagerImpl.java b/branches/sca-java-1.x/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/impl/WorkspaceManagerImpl.java deleted file mode 100644 index f95f74ab2c..0000000000 --- a/branches/sca-java-1.x/modules/workspace-manager/src/main/java/org/apache/tuscany/sca/workspace/manager/impl/WorkspaceManagerImpl.java +++ /dev/null @@ -1,190 +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.sca.workspace.manager.impl; - -import java.io.File; -import java.net.URI; -import java.util.HashSet; -import java.util.List; -import java.util.Set; - -import org.apache.tuscany.sca.contribution.Contribution; -import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint; -import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessor; -import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessorExtensionPoint; -import org.apache.tuscany.sca.contribution.resolver.ExtensibleModelResolver; -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.core.UtilityExtensionPoint; -import org.apache.tuscany.sca.host.embedded.impl.ReallySmallRuntime; -import org.apache.tuscany.sca.monitor.Monitor; -import org.apache.tuscany.sca.monitor.MonitorFactory; -import org.apache.tuscany.sca.monitor.Problem; -import org.apache.tuscany.sca.monitor.Problem.Severity; -import org.apache.tuscany.sca.workspace.Workspace; -import org.apache.tuscany.sca.workspace.WorkspaceFactory; -import org.apache.tuscany.sca.workspace.builder.ContributionDependencyBuilder; -import org.apache.tuscany.sca.workspace.builder.impl.ContributionDependencyBuilderImpl; -import org.apache.tuscany.sca.workspace.manager.WorkspaceManager; -import org.osoa.sca.ServiceRuntimeException; - -/** - * This workspace manager class provides an SPI for firing up the Tuscany runtime - * and for providing access to the Tuscany ExtensionPointRegsitry. With a reference to the - * registry you can add new extension points programmatically before starting the runtime. - * Once the runtime is started you can read contributions, create a workspace, populate it - * and then resolve it. - * - * A workspace is a collection of contributions. A workspace populated - * with one or more contribution models can be resolved to ensure - * that all referenced artifacts are located. When more than one contribution - * model is present resolution takes into account the import and export relationships - * between contributions. - */ -public class WorkspaceManagerImpl extends WorkspaceManager { - - private ReallySmallRuntime runtime; - - private ModelFactoryExtensionPoint modelFactories; - private URLArtifactProcessorExtensionPoint artifactProcessorExtensions; - private UtilityExtensionPoint utilities; - - private WorkspaceFactory workspaceFactory; - private URLArtifactProcessor<Contribution> contributionProcessor; - private ContributionDependencyBuilder contributionDependencyBuilder; - private MonitorFactory monitorFactory; - private Monitor monitor; - - public WorkspaceManagerImpl() throws ServiceRuntimeException{ - try { - runtime = new ReallySmallRuntime(Thread.currentThread().getContextClassLoader()); - - ExtensionPointRegistry registry = getRegistry(); - - modelFactories = registry.getExtensionPoint(ModelFactoryExtensionPoint.class); - artifactProcessorExtensions = registry.getExtensionPoint(URLArtifactProcessorExtensionPoint.class); - utilities = registry.getExtensionPoint(UtilityExtensionPoint.class); - - workspaceFactory = modelFactories.getFactory(WorkspaceFactory.class); - contributionProcessor = artifactProcessorExtensions.getProcessor(Contribution.class); - monitorFactory = utilities.getUtility(MonitorFactory.class); - monitor = monitorFactory.createMonitor(); - - contributionDependencyBuilder = new ContributionDependencyBuilderImpl(monitor); - - } catch(Exception ex) { - throw new ServiceRuntimeException(ex); - } - } - - public ExtensionPointRegistry getRegistry(){ - return runtime.getExtensionPointRegistry(); - } - - public void start() throws ServiceRuntimeException { - try { - runtime.start(); - } catch(Exception ex) { - throw new ServiceRuntimeException(ex); - } - } - - public void stop() throws ServiceRuntimeException{ - try { - runtime.stop(); - } catch(Exception ex) { - throw new ServiceRuntimeException(ex); - } - } - - public Workspace createWorkspace(){ - Workspace workspace = workspaceFactory.createWorkspace(); - - workspace.setModelResolver(new ExtensibleModelResolver(workspace, getRegistry())); - - return workspace; - } - - - public Contribution readContribution(String name, String location) throws ServiceRuntimeException{ - try { - Contribution returnContribution = - contributionProcessor.read(null, - URI.create(name), - new File(location).toURI().toURL()); - - analyzeProblems(); - - return returnContribution; - - } catch (Exception ex) { - throw new ServiceRuntimeException(ex); - } - } - - public void addContributionToWorkspace(Workspace workspace, Contribution contribution) throws ServiceRuntimeException{ - try { - - workspace.getContributions().add(contribution); - - - } catch (Exception ex) { - throw new ServiceRuntimeException(ex); - } - } - - public void resolveWorkspace(Workspace workspace) throws ServiceRuntimeException { - try { - // an algorithm to resolve contributions given their dependencies - // need to look at the one from 2.x as this one expects contributions - // to be presented in the right order - Set<Contribution> resolved = new HashSet<Contribution>(); - for (Contribution contribution: workspace.getContributions()) { - List<Contribution> dependencies = contributionDependencyBuilder.buildContributionDependencies(contribution, workspace); - - // Resolve contributions - for (Contribution dependency: dependencies) { - if (!resolved.contains(dependency)) { - resolved.add(dependency); - contributionProcessor.resolve(contribution, workspace.getModelResolver()); - } - } - } - - analyzeProblems(); - - } catch (Exception ex) { - throw new ServiceRuntimeException(ex); - } - } - - private void analyzeProblems() throws Exception { - - for (Problem problem : monitor.getProblems()) { - if ((problem.getSeverity() == Severity.ERROR) && (!problem.getMessageId().equals("SchemaError"))) { - if (problem.getCause() != null) { - throw problem.getCause(); - } else { - throw new ServiceRuntimeException(problem.toString()); - } - } - } - } - -} |