Start a new module looking at integration with Webbeans and JSR330

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

6 files changed, 393 insertions, 0 deletions

diff --git a/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330Implementation.java b/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330Implementation.java
new file mode 100644
index 0000000000..76106faaeb
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330Implementation.java
@@ -0,0 +1,138 @@
+/*

+ * 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.webbeans;

+

+import java.util.ArrayList;

+import java.util.Collections;

+import java.util.List;

+

+import javax.xml.namespace.QName;

+

+import org.apache.tuscany.sca.assembly.Component;

+import org.apache.tuscany.sca.assembly.Property;

+import org.apache.tuscany.sca.assembly.Reference;

+import org.apache.tuscany.sca.assembly.Service;

+import org.apache.tuscany.sca.assembly.impl.ImplementationImpl;

+import org.apache.tuscany.sca.runtime.RuntimeComponent;

+

+

+/**

+ * The model representing an Web implementation in an SCA assembly model.

+ */

+class JSR330Implementation extends ImplementationImpl {

+

+    public static final QName TYPE = new QName(SCA11_TUSCANY_NS, "implementation.jsr330");

+

+    private List<Property> properties = new ArrayList<Property>();

+    private List<Reference> references = new ArrayList<Reference>();

+    private String uri;

+    private boolean unresolved;

+    private String location;

+

+    /**

+     * Constructs a new Web implementation.

+     */

+    JSR330Implementation() {

+        super(TYPE);

+    }

+

+    public List<Property> getProperties() {

+        return properties;

+    }

+

+    public List<Service> getServices() {

+        // The Web implementation does not offer services

+        return Collections.emptyList();

+    }

+

+    public List<Reference> getReferences() {

+        return references;

+    }

+

+    public String getURI() {

+        return uri;

+    }

+

+    public void setURI(String uri) {

+        this.uri = uri;

+    }

+

+    public boolean isUnresolved() {

+        return unresolved;

+    }

+

+    public void setUnresolved(boolean unresolved) {

+        this.unresolved = unresolved;

+    }

+

+    public String getLocation() {

+        return location;

+    }

+

+    public void setLocation(String location) {

+        this.location = location;

+    }

+

+    /**

+     * Use preProcess to add any references and properties dynamically

+     * TODO: support introspection

+     */

+    public void build(Component component) {

+        if (!(component instanceof RuntimeComponent)) {

+            return;

+        }

+

+        RuntimeComponent rtc = (RuntimeComponent) component;

+

+        for (Reference reference : rtc.getReferences()) {

+            if (getReference(reference.getName()) == null) {

+                getReferences().add(createReference(reference));

+            }

+        }

+

+        for (Property property : rtc.getProperties()) {

+            if (getProperty(property.getName()) == null) {

+                getProperties().add(createProperty(property));

+            }

+        }

+    }

+

+

+    protected Reference createReference(Reference reference) {

+        Reference newReference;

+        try {

+            newReference = (Reference)reference.clone();

+        } catch (CloneNotSupportedException e) {

+            throw new AssertionError(e); // should not ever happen

+        }

+        return newReference;

+    }

+

+

+    protected Property createProperty(Property property) {

+        Property newProperty;

+        try {

+            newProperty = (Property)property.clone();

+        } catch (CloneNotSupportedException e) {

+            throw new AssertionError(e); // should not ever happen

+        }

+        return newProperty;

+    }

+

+}

diff --git a/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330ImplementationBuilder.java b/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330ImplementationBuilder.java
new file mode 100644
index 0000000000..e1c2406e54
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330ImplementationBuilder.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.webbeans;

+

+import javax.xml.namespace.QName;

+

+import org.apache.tuscany.sca.assembly.Component;

+import org.apache.tuscany.sca.assembly.builder.BuilderContext;

+import org.apache.tuscany.sca.assembly.builder.ImplementationBuilder;

+

+/**

+ * 

+ */

+public class JSR330ImplementationBuilder implements ImplementationBuilder<JSR330Implementation> {

+

+    public void build(Component component, JSR330Implementation implmentation, BuilderContext context) {

+        ((JSR330Implementation)implmentation).build(component);

+

+    }

+

+    public QName getImplementationType() {

+        return JSR330Implementation.TYPE;

+    }

+

+}

diff --git a/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330ImplementationProcessor.java b/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330ImplementationProcessor.java
new file mode 100644
index 0000000000..d1cff0c6f2
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/JSR330ImplementationProcessor.java
@@ -0,0 +1,119 @@
+/*

+ * 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.webbeans;

+

+import static javax.xml.stream.XMLStreamConstants.END_ELEMENT;

+

+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.ComponentType;

+import org.apache.tuscany.sca.contribution.processor.BaseStAXArtifactProcessor;

+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.contribution.processor.StAXArtifactProcessor;

+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;

+import org.apache.tuscany.sca.core.ExtensionPointRegistry;

+import org.apache.tuscany.sca.core.FactoryExtensionPoint;

+import org.apache.tuscany.sca.monitor.Monitor;

+import org.apache.tuscany.sca.monitor.Problem;

+import org.apache.tuscany.sca.monitor.Problem.Severity;

+

+/**

+ * Implements a StAX artifact processor for Web implementations.

+ */

+public class JSR330ImplementationProcessor extends BaseStAXArtifactProcessor implements StAXArtifactProcessor<JSR330Implementation> {

+    

+    private AssemblyFactory assemblyFactory;

+    

+    public JSR330ImplementationProcessor(ExtensionPointRegistry extensionPoints) {

+        FactoryExtensionPoint modelFactories = extensionPoints.getExtensionPoint(FactoryExtensionPoint.class);

+        this.assemblyFactory = modelFactories.getFactory(AssemblyFactory.class);

+    }

+

+    public QName getArtifactType() {

+        return JSR330Implementation.TYPE;

+    }

+

+    public Class<JSR330Implementation> getModelType() {

+        return JSR330Implementation.class;

+    }

+

+    public JSR330Implementation read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException {

+        

+        JSR330Implementation implementation = new JSR330Implementation();

+        implementation.setUnresolved(true);

+

+        String location = getString(reader, "location");

+        if (location == null) {

+            Monitor monitor = context.getMonitor();

+            Problem problem = monitor.createProblem(this.getClass().getName(),

+                                      "webbeans-validation-messages",

+                                      Severity.ERROR,

+                                      reader,

+                                      "LocationAttributeMissing");

+            monitor.problem(problem);

+        }

+

+        implementation.setLocation(location);

+

+        // Skip to end element

+        while (reader.hasNext()) {

+            if (reader.next() == END_ELEMENT && JSR330Implementation.TYPE.equals(reader.getName())) {

+                break;

+            }

+        }

+        

+        return implementation;

+    }

+

+    public void write(JSR330Implementation implementation, XMLStreamWriter writer, ProcessorContext context) throws ContributionWriteException, XMLStreamException {

+        

+        // Write <implementation.jsr330>

+        writeStart(writer, JSR330Implementation.TYPE.getNamespaceURI(), JSR330Implementation.TYPE.getLocalPart(),

+                   new XAttr("location", implementation.getLocation()));

+        

+        writeEnd(writer);

+    }

+

+    public void resolve(JSR330Implementation implementation, ModelResolver resolver, ProcessorContext context) throws ContributionResolveException {

+        

+        // Resolve the component type

+        String uri = implementation.getURI();

+        if (uri != null) {

+            ComponentType componentType = assemblyFactory.createComponentType();

+            componentType.setURI("jsr330.componentType");

+            componentType = resolver.resolveModel(ComponentType.class, componentType, context);

+            if (!componentType.isUnresolved()) {

+                

+                // Initialize the implementation's services, references and properties

+                implementation.getServices().addAll(componentType.getServices());

+                implementation.getReferences().addAll(componentType.getReferences());

+                implementation.getProperties().addAll(componentType.getProperties());

+            }

+        }

+        implementation.setUnresolved(false);

+    }

+

+}

diff --git a/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/WebImplementationProviderFactory.java b/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/WebImplementationProviderFactory.java
new file mode 100644
index 0000000000..6d4b6df3d5
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/webbeans/src/main/java/org/apache/tuscany/sca/webbeans/WebImplementationProviderFactory.java
@@ -0,0 +1,55 @@
+/*

+ * 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.webbeans;

+

+import org.apache.tuscany.sca.core.ExtensionPointRegistry;

+import org.apache.tuscany.sca.interfacedef.Operation;

+import org.apache.tuscany.sca.invocation.Invoker;

+import org.apache.tuscany.sca.provider.ImplementationProvider;

+import org.apache.tuscany.sca.provider.ImplementationProviderFactory;

+import org.apache.tuscany.sca.runtime.RuntimeComponent;

+import org.apache.tuscany.sca.runtime.RuntimeComponentService;

+

+public class WebImplementationProviderFactory implements ImplementationProviderFactory<JSR330Implementation> {

+

+    public WebImplementationProviderFactory(ExtensionPointRegistry extensionPoints) {

+    }

+

+    public ImplementationProvider createImplementationProvider(RuntimeComponent component, JSR330Implementation implementation) {

+

+        ImplementationProvider impl = new ImplementationProvider() {

+            public Invoker createInvoker(RuntimeComponentService arg0, Operation arg1) {

+                throw new UnsupportedOperationException("Components using implementation.web have no services");

+            }

+            public void start() {

+            }

+            public void stop() {

+            }

+            public boolean supportsOneWayInvocation() {

+                return false;

+            }

+        };

+        return impl;

+    }

+    

+    public Class<JSR330Implementation> getModelType() {

+        return JSR330Implementation.class;

+    }

+    

+}

diff --git a/sca-java-2.x/trunk/modules/webbeans/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.ImplementationBuilder b/sca-java-2.x/trunk/modules/webbeans/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.ImplementationBuilder
new file mode 100644
index 0000000000..c4bf4a9291
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/webbeans/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.ImplementationBuilder
@@ -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.webbeans.JSR330ImplementationBuilder;qname=http://tuscany.apache.org/xmlns/sca/1.1#implementation.jsr330

+

diff --git a/sca-java-2.x/trunk/modules/webbeans/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor b/sca-java-2.x/trunk/modules/webbeans/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor
new file mode 100644
index 0000000000..7f41d525b8
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/webbeans/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor
@@ -0,0 +1,21 @@
+# 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. 
+
+# Implementation class for the artifact processor extension
+org.apache.tuscany.sca.webbeans.JSR330ImplementationProcessor;qname=http://tuscany.apache.org/xmlns/sca/1.1#implementation.jsr330,model=org.apache.tuscany.sca.webbeans.JSR330Implementation
+
+