o JavaEE processors to introspect WAR, JAR and EAR files and create model objects

o JavaEE extensions to create SCA Services, SCA References and SCA Properties from EJB3 business interfaces, Remote EJB3 references and Env Entries.

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

9 files changed, 848 insertions, 0 deletions

diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EarContributionProcessor.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EarContributionProcessor.java
index 3a80c1dd3b..32425e3299 100644
--- a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EarContributionProcessor.java
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EarContributionProcessor.java
@@ -26,6 +26,9 @@ import java.io.InputStream;
 import java.net.MalformedURLException;
 import java.net.URI;
 import java.net.URL;
+import java.net.URLConnection;
+import java.net.URLStreamHandler;
+import java.net.URLStreamHandlerFactory;
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
@@ -37,6 +40,7 @@ import org.apache.tuscany.sca.contribution.PackageType;
 import org.apache.tuscany.sca.contribution.processor.PackageProcessor;
 import org.apache.tuscany.sca.contribution.processor.impl.JarContributionProcessor;
 import org.apache.tuscany.sca.contribution.service.ContributionException;
+import org.eclipse.emf.common.archive.ArchiveURLConnection;
 
 /**
  * Ear Contribution package processor.
@@ -44,9 +48,32 @@ import org.apache.tuscany.sca.contribution.service.ContributionException;
  * @version $Rev$ $Date$
  */
 public class EarContributionProcessor implements PackageProcessor {
+    
+    /* Install handler for "archive" */
+    static {
+        URL.setURLStreamHandlerFactory(new URLStreamHandlerFactory() {
+            public URLStreamHandler createURLStreamHandler(String protocol) {
+                if("archive".equalsIgnoreCase(protocol)) {
+                    return new Handler();
+                } else {
+                    return null;
+                }
+            }}
+        );
+    }
+
+    static class Handler extends URLStreamHandler {
+        @Override
+        protected URLConnection openConnection(URL u) throws IOException {
+            return new ArchiveURLConnection(u);
+        }
+    }
 
     public URL getArtifactURL(URL packageSourceURL, URI artifact)
             throws MalformedURLException {
+        if(artifact.toString().equals("")) {
+            return packageSourceURL;
+        }
         if (packageSourceURL.toString().startsWith("archive:")) {
             return new URL(packageSourceURL, artifact.toString());
         } else {
diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EjbArchiveProcessor.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EjbArchiveProcessor.java
new file mode 100644
index 0000000000..ee00451318
--- /dev/null
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EjbArchiveProcessor.java
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.contribution.jee.impl;
+
+import java.io.File;
+import java.net.URI;
+import java.net.URL;
+
+import org.apache.tuscany.sca.contribution.jee.EjbModuleInfo;
+import org.apache.tuscany.sca.contribution.jee.JavaEEIntrospector;
+import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.contribution.service.ContributionReadException;
+import org.apache.tuscany.sca.contribution.service.ContributionResolveException;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.monitor.Monitor;
+
+/**
+ * URLArtifactProcessor for EJB jars.
+ * 
+ * @version $Rev$ $Date$
+ */
+public class EjbArchiveProcessor implements URLArtifactProcessor<EjbModuleInfo> {
+    private JavaEEIntrospector jeeIntrospector;
+    
+    public EjbArchiveProcessor(ExtensionPointRegistry registry, Monitor monitor) {
+         jeeIntrospector = registry.getExtensionPoint(JavaEEIntrospector.class);
+    }
+
+    public String getArtifactType() {
+        return ".jar";
+    }
+
+    public EjbModuleInfo read(URL contributionURL, URI artifactURI, URL artifactURL) throws ContributionReadException {
+        EjbModuleInfo ejbModuleInfo = jeeIntrospector.introspectEjbArchive(artifactURL);
+        ejbModuleInfo.setUri(artifactURI);
+        ejbModuleInfo.setModuleName(new File(artifactURL.getFile()).getName());
+        return ejbModuleInfo;
+    }
+
+    public Class<EjbModuleInfo> getModelType() {
+        return EjbModuleInfo.class;
+    }
+
+    public void resolve(EjbModuleInfo arg0, ModelResolver arg1)
+            throws ContributionResolveException {
+    }
+}
diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EjbModuleInfoImpl.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EjbModuleInfoImpl.java
new file mode 100644
index 0000000000..22d0dec187
--- /dev/null
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/EjbModuleInfoImpl.java
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.contribution.jee.impl;
+
+import java.net.URI;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.tuscany.sca.contribution.jee.EjbInfo;
+import org.apache.tuscany.sca.contribution.jee.EjbModuleInfo;
+
+public class EjbModuleInfoImpl implements EjbModuleInfo {
+
+    private URI uri;
+    private String moduleName;
+    private Map<String, EjbInfo> ejbInfos = new HashMap<String, EjbInfo>();
+    
+    public EjbInfo getEjbInfo(String beanName) {
+        return ejbInfos.get(beanName);
+    }
+
+    public Map<String, EjbInfo> getEjbInfos() {
+        return ejbInfos;
+    }
+
+    public String getModuleName() {
+        return moduleName;
+    }
+
+    public void setModuleName(String moduleName) {
+        this.moduleName = moduleName;
+    }
+
+    public URI getUri() {
+        return uri;
+    }
+
+    public void setUri(URI uri) {
+        this.uri = uri;
+    }
+}
diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEApplicationInfoImpl.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEApplicationInfoImpl.java
new file mode 100644
index 0000000000..993605ebe5
--- /dev/null
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEApplicationInfoImpl.java
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.contribution.jee.impl;
+
+import java.net.URI;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.tuscany.sca.contribution.jee.EjbModuleInfo;
+import org.apache.tuscany.sca.contribution.jee.JavaEEApplicationInfo;
+import org.apache.tuscany.sca.contribution.jee.WebModuleInfo;
+
+public class JavaEEApplicationInfoImpl implements JavaEEApplicationInfo {
+    
+    private URI uri;
+    private String applicationName;
+    private Map<String, EjbModuleInfo> ejbModuleInfos = new HashMap<String, EjbModuleInfo>();
+    private Map<String, WebModuleInfo> webModuleInfos = new HashMap<String, WebModuleInfo>();
+    
+
+    public String getApplicationName() {
+        return applicationName;
+    }
+    
+    public void setApplicationName(String applicationName) {
+        this.applicationName = applicationName;
+    }
+
+    public EjbModuleInfo getEjbModuleInfo(String moduleName) {
+        return ejbModuleInfos.get(moduleName);
+    }
+
+    public Map<String, EjbModuleInfo> getEjbModuleInfos() {
+        return ejbModuleInfos;
+    }
+
+    public WebModuleInfo getWebModuleInfo(String moduleName) {
+        return webModuleInfos.get(moduleName);
+    }
+
+    public Map<String, WebModuleInfo> getWebModuleInfos() {
+        return webModuleInfos;
+    }
+
+    public URI getUri() {
+        return uri;
+    }
+
+    public void setUri(URI uri) {
+        this.uri = uri;
+    }
+}
diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEArchiveProcessor.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEArchiveProcessor.java
new file mode 100644
index 0000000000..65b820c280
--- /dev/null
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEArchiveProcessor.java
@@ -0,0 +1,41 @@
+package org.apache.tuscany.sca.contribution.jee.impl;
+
+import java.io.File;
+import java.net.URI;
+import java.net.URL;
+
+import org.apache.tuscany.sca.contribution.jee.JavaEEApplicationInfo;
+import org.apache.tuscany.sca.contribution.jee.JavaEEIntrospector;
+import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.contribution.service.ContributionReadException;
+import org.apache.tuscany.sca.contribution.service.ContributionResolveException;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.monitor.Monitor;
+
+public class JavaEEArchiveProcessor implements URLArtifactProcessor<JavaEEApplicationInfo> {
+    private JavaEEIntrospector jeeIntrospector;
+    
+    public JavaEEArchiveProcessor(ExtensionPointRegistry registry, Monitor monitor) {
+         jeeIntrospector = registry.getExtensionPoint(JavaEEIntrospector.class);
+    }
+
+    public String getArtifactType() {
+        return ".ear";
+    }
+
+    public JavaEEApplicationInfo read(URL contributionURL, URI artifactURI, URL artifactURL) throws ContributionReadException {
+        JavaEEApplicationInfo jeeAppInfo = jeeIntrospector.introspectJeeArchive(artifactURL);
+        jeeAppInfo.setUri(artifactURI);
+        jeeAppInfo.setApplicationName(new File(artifactURL.getFile()).getName());
+        return jeeAppInfo;
+    }
+
+    public Class<JavaEEApplicationInfo> getModelType() {
+        return JavaEEApplicationInfo.class;
+    }
+
+    public void resolve(JavaEEApplicationInfo arg0, ModelResolver arg1)
+            throws ContributionResolveException {
+    }
+}
diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEExtensionImpl.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEExtensionImpl.java
new file mode 100644
index 0000000000..8d8d0f4c35
--- /dev/null
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEExtensionImpl.java
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.contribution.jee.impl;
+
+import java.util.Map;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.AssemblyFactory;
+import org.apache.tuscany.sca.assembly.ComponentType;
+import org.apache.tuscany.sca.assembly.Service;
+import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;
+import org.apache.tuscany.sca.contribution.jee.EjbInfo;
+import org.apache.tuscany.sca.contribution.jee.EjbModuleInfo;
+import org.apache.tuscany.sca.contribution.jee.JavaEEApplicationInfo;
+import org.apache.tuscany.sca.contribution.jee.JavaEEExtension;
+import org.apache.tuscany.sca.contribution.jee.EjbInfo.EjbType;
+import org.apache.tuscany.sca.interfacedef.InterfaceContract;
+import org.apache.tuscany.sca.interfacedef.InvalidInterfaceException;
+import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory;
+import org.apache.tuscany.sca.policy.Intent;
+import org.apache.tuscany.sca.policy.PolicyFactory;
+
+public class JavaEEExtensionImpl implements JavaEEExtension {
+    
+    private AssemblyFactory assemblyFactory;
+    private JavaInterfaceFactory javaInterfaceFactory;
+    private PolicyFactory policyFactory;
+    private Intent EJB_INTENT;
+    
+    public JavaEEExtensionImpl(ModelFactoryExtensionPoint modelFactories) {
+        this.assemblyFactory = modelFactories.getFactory(AssemblyFactory.class);
+        this.javaInterfaceFactory = modelFactories.getFactory(JavaInterfaceFactory.class);
+        this.policyFactory = modelFactories.getFactory(PolicyFactory.class);
+        
+        EJB_INTENT = policyFactory.createIntent();
+        EJB_INTENT.setName(new QName("http://www.osoa.org/xmlns/sca/1.0", "ejb"));
+    }
+    
+    public ComponentType createImplementationEjbComponentType(EjbModuleInfo ejbModule, String ejbName) {
+        ComponentType componentType = assemblyFactory.createComponentType();
+        EjbInfo ejbInfo = ejbModule.getEjbInfo(ejbName);
+        if(ejbInfo == null) {
+            return null;
+        }
+        if(ejbInfo.ejbType.compareTo(EjbType.MESSAGE_DRIVEN) != 0) {
+            for(Class<?> intf : ejbInfo.businessRemote) {
+                Service service = assemblyFactory.createComponentService();
+                String intfName = intf.getName();
+                String serviceName = intfName.lastIndexOf(".") != -1 ? intfName.substring(intfName.lastIndexOf(".") + 1) : intfName;
+                service.setName(serviceName);
+                InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+                try {
+                    ic.setInterface(javaInterfaceFactory.createJavaInterface(intf));
+                } catch (InvalidInterfaceException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                service.setInterfaceContract(ic);
+                componentType.getServices().add(service);
+            }
+
+            for(Class<?> intf : ejbInfo.businessLocal) {
+                Service service = assemblyFactory.createComponentService();
+                String intfName = intf.getName();
+                String serviceName = intfName.lastIndexOf(".") != -1 ? intfName.substring(intfName.lastIndexOf(".") + 1) : intfName;
+                service.setName(serviceName);
+                InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+                try {
+                    ic.setInterface(javaInterfaceFactory.createJavaInterface(intf));
+                } catch (InvalidInterfaceException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                service.setInterfaceContract(ic);
+                service.getRequiredIntents().add(EJB_INTENT);
+                
+                componentType.getServices().add(service);
+            }
+        }
+        return componentType;
+    }
+    
+    public ComponentType createImplementationJeeComponentType(EjbModuleInfo ejbModule) {
+        ComponentType componentType = assemblyFactory.createComponentType();
+        
+        for(Map.Entry<String, EjbInfo> entry : ejbModule.getEjbInfos().entrySet()) {
+            EjbInfo ejbInfo = entry.getValue();
+            if(ejbInfo.ejbType.compareTo(EjbType.MESSAGE_DRIVEN) != 0) {
+                for(Class<?> intf : ejbInfo.businessRemote) {
+                    Service service = assemblyFactory.createComponentService();
+                    String intfName = intf.getName();
+                    String serviceName = intfName.lastIndexOf(".") != -1 ? intfName.substring(intfName.lastIndexOf(".") + 1) : intfName;
+                    serviceName = ejbInfo.beanName+"_"+serviceName;
+                    service.setName(serviceName);
+                    InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+                    try {
+                        ic.setInterface(javaInterfaceFactory.createJavaInterface(intf));
+                    } catch (InvalidInterfaceException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                    service.setInterfaceContract(ic);
+                    componentType.getServices().add(service);
+                }
+
+                for(Class<?> intf : ejbInfo.businessLocal) {
+                    Service service = assemblyFactory.createComponentService();
+                    String intfName = intf.getName();
+                    String serviceName = intfName.lastIndexOf(".") != -1 ? intfName.substring(intfName.lastIndexOf(".") + 1) : intfName;
+                    serviceName = ejbInfo.beanName+"_"+serviceName;
+                    service.setName(serviceName);
+                    InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+                    try {
+                        ic.setInterface(javaInterfaceFactory.createJavaInterface(intf));
+                    } catch (InvalidInterfaceException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                    service.setInterfaceContract(ic);
+                    service.getRequiredIntents().add(EJB_INTENT);
+                    
+                    componentType.getServices().add(service);
+                }
+            }
+        }
+        
+        return componentType;
+    }
+
+    public ComponentType createImplementationJeeComponentType(JavaEEApplicationInfo appInfo) {
+        ComponentType componentType = assemblyFactory.createComponentType();
+        
+        for(Map.Entry<String, EjbModuleInfo> entry0 : appInfo.getEjbModuleInfos().entrySet()) {
+            EjbModuleInfo ejbModule = entry0.getValue();
+            
+            for(Map.Entry<String, EjbInfo> entry : ejbModule.getEjbInfos().entrySet()) {
+                EjbInfo ejbInfo = entry.getValue();
+                if(ejbInfo.ejbType.compareTo(EjbType.MESSAGE_DRIVEN) != 0) {
+                    for(Class<?> intf : ejbInfo.businessRemote) {
+                        Service service = assemblyFactory.createComponentService();
+                        String intfName = intf.getName();
+                        String serviceName = intfName.lastIndexOf(".") != -1 ? intfName.substring(intfName.lastIndexOf(".") + 1) : intfName;
+                        serviceName = ejbInfo.mappedName+"_"+serviceName;
+                        service.setName(serviceName);
+                        InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+                        try {
+                            ic.setInterface(javaInterfaceFactory.createJavaInterface(intf));
+                        } catch (InvalidInterfaceException e) {
+                            // TODO Auto-generated catch block
+                            e.printStackTrace();
+                        }
+                        service.setInterfaceContract(ic);
+                        componentType.getServices().add(service);
+                    }
+
+                    for(Class<?> intf : ejbInfo.businessLocal) {
+                        Service service = assemblyFactory.createComponentService();
+                        String intfName = intf.getName();
+                        String serviceName = intfName.lastIndexOf(".") != -1 ? intfName.substring(intfName.lastIndexOf(".") + 1) : intfName;
+                        serviceName = ejbInfo.mappedName+"_"+serviceName;
+                        service.setName(serviceName);
+                        InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+                        try {
+                            ic.setInterface(javaInterfaceFactory.createJavaInterface(intf));
+                        } catch (InvalidInterfaceException e) {
+                            // TODO Auto-generated catch block
+                            e.printStackTrace();
+                        }
+                        service.setInterfaceContract(ic);
+                        service.getRequiredIntents().add(EJB_INTENT);
+                        
+                        componentType.getServices().add(service);
+                    }
+                }
+            }
+        }
+        
+        return componentType;
+    }
+}
diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEOptionalExtensionImpl.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEOptionalExtensionImpl.java
new file mode 100644
index 0000000000..f02b74bd8d
--- /dev/null
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEOptionalExtensionImpl.java
@@ -0,0 +1,259 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.contribution.jee.impl;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.sca.assembly.AssemblyFactory;
+import org.apache.tuscany.sca.assembly.ComponentType;
+import org.apache.tuscany.sca.assembly.Multiplicity;
+import org.apache.tuscany.sca.assembly.Property;
+import org.apache.tuscany.sca.assembly.Reference;
+import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;
+import org.apache.tuscany.sca.contribution.jee.EjbInfo;
+import org.apache.tuscany.sca.contribution.jee.EjbModuleInfo;
+import org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo;
+import org.apache.tuscany.sca.contribution.jee.EnvEntryInfo;
+import org.apache.tuscany.sca.contribution.jee.JavaEEApplicationInfo;
+import org.apache.tuscany.sca.contribution.jee.JavaEEOptionalExtension;
+import org.apache.tuscany.sca.contribution.jee.WebModuleInfo;
+import org.apache.tuscany.sca.interfacedef.InterfaceContract;
+import org.apache.tuscany.sca.interfacedef.InvalidInterfaceException;
+import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory;
+import org.apache.tuscany.sca.policy.Intent;
+import org.apache.tuscany.sca.policy.PolicyFactory;
+
+public class JavaEEOptionalExtensionImpl implements JavaEEOptionalExtension {
+    
+    private AssemblyFactory assemblyFactory;
+    private JavaInterfaceFactory javaInterfaceFactory;
+    private PolicyFactory policyFactory;
+    private Intent EJB_INTENT;
+    
+    public static final Map<String, QName> ALLOWED_ENV_ENTRY_TYPES;
+    static {
+        ALLOWED_ENV_ENTRY_TYPES = new HashMap<String, QName>();
+        ALLOWED_ENV_ENTRY_TYPES.put(String.class.getName(), new QName("http://www.w3.org/2001/XMLSchema", "string",
+                                                                      "xsd"));
+        ALLOWED_ENV_ENTRY_TYPES.put(Character.class.getName(), new QName("http://www.w3.org/2001/XMLSchema", "string",
+                                                                         "xsd"));
+        ALLOWED_ENV_ENTRY_TYPES.put(Byte.class.getName(), new QName("http://www.w3.org/2001/XMLSchema", "byte", "xsd"));
+        ALLOWED_ENV_ENTRY_TYPES.put(Short.class.getName(),
+                                    new QName("http://www.w3.org/2001/XMLSchema", "short", "xsd"));
+        ALLOWED_ENV_ENTRY_TYPES.put(Integer.class.getName(),
+                                    new QName("http://www.w3.org/2001/XMLSchema", "int", "xsd"));
+        ALLOWED_ENV_ENTRY_TYPES.put(Long.class.getName(), new QName("http://www.w3.org/2001/XMLSchema", "long", "xsd"));
+        ALLOWED_ENV_ENTRY_TYPES.put(Boolean.class.getName(), new QName("http://www.w3.org/2001/XMLSchema", "boolean",
+                                                                       "xsd"));
+        ALLOWED_ENV_ENTRY_TYPES.put(Double.class.getName(), new QName("http://www.w3.org/2001/XMLSchema", "double",
+                                                                      "xsd"));
+        ALLOWED_ENV_ENTRY_TYPES.put(Float.class.getName(),
+                                    new QName("http://www.w3.org/2001/XMLSchema", "float", "xsd"));
+    }
+
+    public JavaEEOptionalExtensionImpl(ModelFactoryExtensionPoint modelFactories) {
+        this.assemblyFactory = modelFactories.getFactory(AssemblyFactory.class);
+        this.javaInterfaceFactory = modelFactories.getFactory(JavaInterfaceFactory.class);
+        this.policyFactory = modelFactories.getFactory(PolicyFactory.class);
+        
+        EJB_INTENT = policyFactory.createIntent();
+        EJB_INTENT.setName(new QName("http://www.osoa.org/xmlns/sca/1.0", "ejb"));
+    }
+    
+    public ComponentType createImplementationWebComponentType(WebModuleInfo webModule) {
+        ComponentType componentType = assemblyFactory.createComponentType();
+        
+        // Process Remote EJB References
+        for(Map.Entry<String, EjbReferenceInfo> entry : webModule.getEjbReferences().entrySet()) {
+            EjbReferenceInfo ejbRef = entry.getValue();
+            String referenceName = entry.getKey();
+            referenceName = referenceName.replace("/", "_");
+            Reference reference = assemblyFactory.createComponentReference();
+            reference.setName(referenceName);
+            InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+            try {
+                ic.setInterface(javaInterfaceFactory.createJavaInterface(ejbRef.businessInterface));
+            } catch (InvalidInterfaceException e) {
+                // TODO Auto-generated catch block
+                e.printStackTrace();
+            }
+            reference.setInterfaceContract(ic);
+            reference.getRequiredIntents().add(EJB_INTENT);
+            reference.setMultiplicity(Multiplicity.ZERO_ONE);
+            componentType.getReferences().add(reference);
+        }
+        
+        // Process env-entries to compute properties
+        for (Map.Entry<String, EnvEntryInfo> entry : webModule.getEnvEntries().entrySet()) {
+            EnvEntryInfo envEntry = entry.getValue();
+            String type = envEntry.type;
+            if (!ALLOWED_ENV_ENTRY_TYPES.containsKey(type)) {
+                continue;
+            }
+            String propertyName = envEntry.name;
+            propertyName = propertyName.replace("/", "_");
+            String value = envEntry.value;
+            Property property = assemblyFactory.createComponentProperty();
+            property.setName(propertyName);
+            property.setXSDType(ALLOWED_ENV_ENTRY_TYPES.get(type));
+            property.setValue(value);
+            componentType.getProperties().add(property);
+        }
+        
+        return componentType;
+    }
+    public ComponentType createImplementationEjbComponentType(EjbModuleInfo ejbModule, String ejbName) {
+        ComponentType componentType = assemblyFactory.createComponentType();
+        EjbInfo ejbInfo = ejbModule.getEjbInfo(ejbName);
+        if(ejbInfo == null) {
+            return null;
+        }
+
+        // Process Remote EJB References
+        for(Map.Entry<String, EjbReferenceInfo> entry : ejbInfo.ejbReferences.entrySet()) {
+            EjbReferenceInfo ejbRef = entry.getValue();
+            String referenceName = entry.getKey();
+            referenceName = referenceName.replace("/", "_");
+            Reference reference = assemblyFactory.createComponentReference();
+            reference.setName(referenceName);
+            InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+            try {
+                ic.setInterface(javaInterfaceFactory.createJavaInterface(ejbRef.businessInterface));
+            } catch (InvalidInterfaceException e) {
+                // TODO Auto-generated catch block
+                e.printStackTrace();
+            }
+            reference.setInterfaceContract(ic);
+            reference.getRequiredIntents().add(EJB_INTENT);
+            reference.setMultiplicity(Multiplicity.ZERO_ONE);
+            componentType.getReferences().add(reference);
+        }
+        
+        // Process env-entries to compute properties
+        for (Map.Entry<String, EnvEntryInfo> entry : ejbInfo.envEntries.entrySet()) {
+            EnvEntryInfo envEntry = entry.getValue();
+            String type = envEntry.type;
+            if (!ALLOWED_ENV_ENTRY_TYPES.containsKey(type)) {
+                continue;
+            }
+            String propertyName = envEntry.name;
+            propertyName = propertyName.replace("/", "_");
+            String value = envEntry.value;
+            Property property = assemblyFactory.createComponentProperty();
+            property.setName(propertyName);
+            property.setXSDType(ALLOWED_ENV_ENTRY_TYPES.get(type));
+            property.setValue(value);
+            componentType.getProperties().add(property);
+        }
+        return componentType;
+    }
+    
+    public ComponentType createImplementationJeeComponentType(WebModuleInfo webModule) {
+        ComponentType componentType = assemblyFactory.createComponentType();
+        
+        // Process Remote EJB References
+        for(Map.Entry<String, EjbReferenceInfo> entry : webModule.getEjbReferences().entrySet()) {
+            EjbReferenceInfo ejbRef = entry.getValue();
+            String referenceName = entry.getKey();
+            referenceName = referenceName.replace("/", "_");
+            Reference reference = assemblyFactory.createComponentReference();
+            reference.setName(referenceName);
+            InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+            try {
+                ic.setInterface(javaInterfaceFactory.createJavaInterface(ejbRef.businessInterface));
+            } catch (InvalidInterfaceException e) {
+                // TODO Auto-generated catch block
+                e.printStackTrace();
+            }
+            reference.setInterfaceContract(ic);
+            reference.getRequiredIntents().add(EJB_INTENT);
+            reference.setMultiplicity(Multiplicity.ZERO_ONE);
+            componentType.getReferences().add(reference);
+        }
+        
+        return componentType;
+    }
+
+    public ComponentType createImplementationJeeComponentType(EjbModuleInfo ejbModule) {
+        ComponentType componentType = assemblyFactory.createComponentType();
+        
+        for(Map.Entry<String, EjbInfo> entry : ejbModule.getEjbInfos().entrySet()) {
+            EjbInfo ejbInfo = entry.getValue();
+            // Process Remote EJB References
+            for(Map.Entry<String, EjbReferenceInfo> entry1 : ejbInfo.ejbReferences.entrySet()) {
+                EjbReferenceInfo ejbRef = entry1.getValue();
+                String referenceName = ejbRef.referenceName;
+                referenceName = referenceName.replace("/", "_");
+                referenceName = ejbInfo.beanName + "_" + referenceName;
+                Reference reference = assemblyFactory.createComponentReference();
+                reference.setName(referenceName);
+                InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+                try {
+                    ic.setInterface(javaInterfaceFactory.createJavaInterface(ejbRef.businessInterface));
+                } catch (InvalidInterfaceException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                reference.setInterfaceContract(ic);
+                reference.getRequiredIntents().add(EJB_INTENT);
+                reference.setMultiplicity(Multiplicity.ZERO_ONE);
+                componentType.getReferences().add(reference);
+            }
+        }
+        
+        return componentType;
+    }
+
+    public ComponentType createImplementationJeeComponentType(JavaEEApplicationInfo appInfo) {
+        ComponentType componentType = assemblyFactory.createComponentType();
+        
+        for(Map.Entry<String, EjbModuleInfo> entry0 : appInfo.getEjbModuleInfos().entrySet()) {
+            EjbModuleInfo ejbModule = entry0.getValue();
+            
+            for(Map.Entry<String, EjbInfo> entry : ejbModule.getEjbInfos().entrySet()) {
+                EjbInfo ejbInfo = entry.getValue();
+                // Process Remote EJB References
+                for(Map.Entry<String, EjbReferenceInfo> entry1 : ejbInfo.ejbReferences.entrySet()) {
+                    EjbReferenceInfo ejbRef = entry1.getValue();
+                    String referenceName = ejbRef.referenceName;
+                    referenceName = referenceName.replace("/", "_");
+                    referenceName = ejbInfo.beanName + "_" + referenceName;
+                    Reference reference = assemblyFactory.createComponentReference();
+                    reference.setName(referenceName);
+                    InterfaceContract ic = javaInterfaceFactory.createJavaInterfaceContract();
+                    try {
+                        ic.setInterface(javaInterfaceFactory.createJavaInterface(ejbRef.businessInterface));
+                    } catch (InvalidInterfaceException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                    reference.setInterfaceContract(ic);
+                    reference.getRequiredIntents().add(EJB_INTENT);
+                    reference.setMultiplicity(Multiplicity.ZERO_ONE);
+                    componentType.getReferences().add(reference);
+                }
+            }
+        }
+        
+        return componentType;
+    }
+}
diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/WebArchiveProcessor.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/WebArchiveProcessor.java
new file mode 100644
index 0000000000..8eff7e772e
--- /dev/null
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/WebArchiveProcessor.java
@@ -0,0 +1,59 @@
+package org.apache.tuscany.sca.contribution.jee.impl;
+
+import java.io.File;
+import java.net.URI;
+import java.net.URL;
+
+import org.apache.tuscany.sca.contribution.jee.JavaEEIntrospector;
+import org.apache.tuscany.sca.contribution.jee.WebModuleInfo;
+import org.apache.tuscany.sca.contribution.processor.URLArtifactProcessor;
+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;
+import org.apache.tuscany.sca.contribution.service.ContributionReadException;
+import org.apache.tuscany.sca.contribution.service.ContributionResolveException;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.monitor.Monitor;
+
+/*
+ * 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.    
+ */
+public class WebArchiveProcessor implements URLArtifactProcessor<WebModuleInfo> {
+    private JavaEEIntrospector jeeIntrospector;
+    
+    public WebArchiveProcessor(ExtensionPointRegistry registry, Monitor monitor) {
+         jeeIntrospector = registry.getExtensionPoint(JavaEEIntrospector.class);
+    }
+
+    public String getArtifactType() {
+        return ".war";
+    }
+
+    public WebModuleInfo read(URL contributionURL, URI artifactURI, URL artifactURL) throws ContributionReadException {
+        WebModuleInfo webModuleInfo = jeeIntrospector.introspectWebArchive(artifactURL);
+        webModuleInfo.setUri(artifactURI);
+        webModuleInfo.setModuleName(new File(artifactURL.getFile()).getName());
+        return webModuleInfo;
+    }
+
+    public Class<WebModuleInfo> getModelType() {
+        return WebModuleInfo.class;
+    }
+
+    public void resolve(WebModuleInfo arg0, ModelResolver arg1)
+            throws ContributionResolveException {
+    }
+}
diff --git a/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/WebModuleInfoImpl.java b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/WebModuleInfoImpl.java
new file mode 100644
index 0000000000..353ac7b5c5
--- /dev/null
+++ b/branches/sca-java-1.x/modules/contribution-jee/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/WebModuleInfoImpl.java
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.    
+ */
+package org.apache.tuscany.sca.contribution.jee.impl;
+
+import java.net.URI;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo;
+import org.apache.tuscany.sca.contribution.jee.EnvEntryInfo;
+import org.apache.tuscany.sca.contribution.jee.WebModuleInfo;
+
+public class WebModuleInfoImpl implements WebModuleInfo {
+    
+    private URI uri;
+    private String moduleName;
+    private Collection<Class<?>> classesToScan = new ArrayList<Class<?>>();
+    private Map<String, EjbReferenceInfo> ejbReferences = new HashMap<String, EjbReferenceInfo>();
+    private Map<String, EnvEntryInfo> envEntries = new HashMap<String, EnvEntryInfo>();
+
+    public WebModuleInfoImpl() {
+    }
+    public Collection<Class<?>> getClassesToScan() {
+        return classesToScan;
+    }
+
+    public EjbReferenceInfo getEjbReference(String ejbRefName) {
+        return ejbReferences.get(ejbRefName);
+    }
+
+    public Map<String, EjbReferenceInfo> getEjbReferences() {
+        return ejbReferences;
+    }
+
+    public Map<String, EnvEntryInfo> getEnvEntries() {
+        return envEntries;
+    }
+
+    public EnvEntryInfo getEnvEntry(String envEntryName) {
+        return envEntries.get(envEntryName);
+    }
+
+    public String getModuleName() {
+        return moduleName;
+    }
+
+    public void setModuleName(String moduleName) {
+        this.moduleName = moduleName;
+    }
+    
+    public URI getUri() {
+        return uri;
+    }
+    
+    public void setUri(URI uri) {
+        this.uri = uri;
+    }
+}