summaryrefslogtreecommitdiffstats
path: root/branches/sca-java-1.5/modules/contribution-jee-impl/src
diff options
context:
space:
mode:
authorantelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>2009-04-18 07:36:53 +0000
committerantelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>2009-04-18 07:36:53 +0000
commit6c7ad7c110656f47273dc23228b41e46023492f3 (patch)
tree348f4838b71e73278bd01153e93db88e22e9c189 /branches/sca-java-1.5/modules/contribution-jee-impl/src
parent5395b820e60118c68eab9c442af3c53e0e2d7f50 (diff)
Create 1.5 branch
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@766260 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'branches/sca-java-1.5/modules/contribution-jee-impl/src')
-rw-r--r--branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/JavaEEModuleHelper.java63
-rw-r--r--branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JEEClassLoader.java330
-rw-r--r--branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JEEClassLoaderProvider.java41
-rw-r--r--branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEIntrospectorImpl.java420
-rw-r--r--branches/sca-java-1.5/modules/contribution-jee-impl/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.java.ContributionClassLoaderProvider17
-rw-r--r--branches/sca-java-1.5/modules/contribution-jee-impl/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.jee.JavaEEIntrospector18
6 files changed, 889 insertions, 0 deletions
diff --git a/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/JavaEEModuleHelper.java b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/JavaEEModuleHelper.java
new file mode 100644
index 0000000000..ccb66e8965
--- /dev/null
+++ b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/JavaEEModuleHelper.java
@@ -0,0 +1,63 @@
+/*
+ * 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;
+
+import java.io.File;
+
+import org.apache.openejb.OpenEJBException;
+import org.apache.openejb.config.AnnotationDeployer;
+import org.apache.openejb.config.AppModule;
+import org.apache.openejb.config.DeploymentLoader;
+import org.apache.openejb.config.ReadDescriptors;
+import org.apache.tuscany.sca.contribution.service.ContributionReadException;
+
+/**
+ * @version $Rev$ $Date$
+ */
+public class JavaEEModuleHelper {
+
+ public AppModule getMetadataCompleteModules(String jarFilePath) throws ContributionReadException {
+ DeploymentLoader loader = new DeploymentLoader();
+ AppModule appModule = null;
+ try {
+ appModule = loader.load(new File(jarFilePath));
+ } catch (OpenEJBException e) {
+ throw new ContributionReadException(e);
+ }
+
+ // Process deployment descriptor files
+ ReadDescriptors readDescriptors = new ReadDescriptors();
+ try {
+ readDescriptors.deploy(appModule);
+ } catch (OpenEJBException e) {
+ throw new ContributionReadException(e);
+ }
+
+ // Process annotations
+ AnnotationDeployer annDeployer = new AnnotationDeployer();
+ try {
+ annDeployer.deploy(appModule);
+ } catch (OpenEJBException e) {
+ throw new ContributionReadException(e);
+ }
+
+ return appModule;
+ }
+}
diff --git a/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JEEClassLoader.java b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JEEClassLoader.java
new file mode 100644
index 0000000000..bc009c50d7
--- /dev/null
+++ b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JEEClassLoader.java
@@ -0,0 +1,330 @@
+/*
+ * 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.IOException;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.security.AccessController;
+import java.security.PrivilegedAction;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Enumeration;
+import java.util.HashSet;
+import java.util.List;
+
+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.java.JavaImport;
+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 JEEClassLoader extends URLClassLoader {
+
+ private Contribution contribution;
+ private List<WebModuleInfo> webModules = new ArrayList<WebModuleInfo>();
+ private List<EjbModuleInfo> ejbModules = new ArrayList<EjbModuleInfo>();
+
+ /**
+ * Constructor for contribution ClassLoader
+ *
+ * @param contribution
+ * @param parent
+ * @throws MalformedURLException
+ */
+ public JEEClassLoader(Contribution contribution, final ClassLoader parent) {
+ super(new URL[0], parent);
+
+ this.contribution = contribution;
+
+ // get the classloaders for any JEE archives references by the contribution
+ // TODO extend to case where JEE archive is outside the contribution
+ for (Artifact artifact : contribution.getArtifacts()){
+ if (artifact.getModel() instanceof WebModuleInfo){
+ WebModuleInfo webModuleInfo = (WebModuleInfo)artifact.getModel();
+ webModules.add(webModuleInfo);
+ } else if (artifact.getModel() instanceof EjbModuleInfo){
+ EjbModuleInfo ejbModuleInfo = (EjbModuleInfo)artifact.getModel();
+ ejbModules.add(ejbModuleInfo);
+ } else if (artifact.getModel() instanceof JavaEEApplicationInfo){
+ JavaEEApplicationInfo jeeAppInfo = (JavaEEApplicationInfo)artifact.getModel();
+ webModules.addAll(jeeAppInfo.getWebModuleInfos().values());
+ ejbModules.addAll(jeeAppInfo.getEjbModuleInfos().values());
+ }
+ }
+
+ }
+
+ /* (non-Javadoc)
+ * @see java.net.URLClassLoader#findClass(java.lang.String)
+ *
+ * Search path for class:
+ * This contribution
+ * Imported contributions
+ */
+ @Override
+ protected Class<?> findClass(String className) throws ClassNotFoundException {
+
+ Class<?> clazz = null;
+ ClassNotFoundException cne = null;
+
+ // ask each of the JEE archive classloaders in turn
+ // TODO This is a bad thing as two archives may have the same class
+ // but don't know how to avoid this
+ for (WebModuleInfo webModuleInfo : webModules){
+ try {
+ clazz = webModuleInfo.getModuleClassloader().loadClass(className);
+ } catch (ClassNotFoundException e) {
+ cne = e;
+ }
+
+ if (clazz != null){
+ break;
+ }
+ }
+
+ // We would expect the webapp classloaders to have an ejb classloader as parent
+ // but we have to go through the ebj module classloaders here just in case
+ // there are no webapps
+ for (EjbModuleInfo ejbModuleInfo : ejbModules){
+ try {
+ clazz = ejbModuleInfo.getModuleClassloader().loadClass(className);
+ } catch (ClassNotFoundException e) {
+ cne = e;
+ }
+
+ if (clazz != null){
+ break;
+ }
+ }
+
+ if (clazz == null){
+ throw cne;
+ }
+
+ return clazz;
+ }
+
+
+ /* (non-Javadoc)
+ * @see java.lang.ClassLoader#loadClass(java.lang.String, boolean)
+ *
+ * Search path for class:
+ * Parent ClassLoader
+ * This contribution
+ * Imported contributions
+ *
+ */
+ @Override
+ protected synchronized Class<?> loadClass(String className, boolean resolveClass)
+ throws ClassNotFoundException {
+
+ Class<?> clazz = null;
+ try {
+
+ if (this.getParent() != null)
+ clazz = this.getParent().loadClass(className);
+
+ } catch (ClassNotFoundException e) {
+ }
+
+ if (clazz == null)
+ clazz = findClass(className);
+
+
+ if (resolveClass)
+ this.resolveClass(clazz);
+ return clazz;
+
+ }
+
+
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see java.net.URLClassLoader#findResource(java.lang.String)
+ */
+ @Override
+ public URL findResource(String name) {
+
+ URL url = null;
+/*
+ URL url = findResourceFromContribution(name);
+
+ if (url == null) {
+ for (Import import_ : this.contribution.getImports()) {
+ if (resourceNameMatchesImport(name, import_)) {
+ // Delegate the resolution to the imported contribution
+ for (Contribution exportingContribution : ((JavaImportModelResolver)import_.getModelResolver()).getExportContributions()) {
+
+ ClassLoader exportClassLoader = getExportClassLoader(exportingContribution);
+ if (exportClassLoader instanceof JEEClassLoader) {
+
+ for (Export export : exportingContribution.getExports()) {
+ if (import_.match(export)) {
+ url = ((JEEClassLoader)exportClassLoader).findResourceFromContribution(name);
+ if (url != null) break;
+ }
+ }
+ if (url != null) break;
+ }
+ }
+ if (url != null) break;
+ }
+ }
+
+ }
+*/
+ return url;
+ }
+
+
+ /* (non-Javadoc)
+ * @see java.net.URLClassLoader#findResources(java.lang.String)
+ */
+ @Override
+ public Enumeration<URL> findResources(String name) throws IOException {
+ return Collections.enumeration(findResourceSet(name));
+ }
+
+ /* (non-Javadoc)
+ * @see java.lang.ClassLoader#getResource(java.lang.String)
+ *
+ * Find a resource.
+ * Search path for resource:
+ * Parent ClassLoader
+ * This contribution
+ * Imported contributions
+ */
+ @Override
+ public URL getResource(String resName) {
+
+ URL resource = null;
+
+ if (this.getParent() != null) {
+ resource = this.getParent().getResource(resName);
+ }
+ if (resource == null)
+ resource = findResource(resName);
+
+ return resource;
+ }
+
+
+
+ /* (non-Javadoc)
+ * @see java.lang.ClassLoader#getResources(java.lang.String)
+ *
+ * Return list of resources from this contribution, resources
+ * imported through imported contributions and resources from parent
+ * ClassLoader.
+ */
+ @Override
+ public Enumeration<URL> getResources(String resName) throws IOException {
+
+ HashSet<URL> resourceSet = findResourceSet(resName);
+ addEnumerationToCollection(resourceSet, super.getResources(resName));
+
+ return Collections.enumeration(resourceSet);
+ }
+
+
+ /*
+ * Find set of resources
+ */
+ private HashSet<URL> findResourceSet(String name) throws IOException {
+
+ HashSet<URL> resources = new HashSet<URL>();
+
+/*
+ addEnumerationToCollection(resources, super.findResources(name));
+
+ for (Import import_ : this.contribution.getImports()) {
+ if (!(import_ instanceof JavaImport)) {
+ continue;
+ }
+ if (resourceNameMatchesImport(name, import_)) {
+ // Delegate the resolution to the imported contribution
+ for (Contribution exportingContribution : ((JavaImportModelResolver)import_.getModelResolver()).getExportContributions()) {
+
+ ClassLoader exportClassLoader = getExportClassLoader(exportingContribution);
+ if (exportClassLoader instanceof JEEClassLoader) {
+
+ for (Export export : exportingContribution.getExports()) {
+ if (import_.match(export)) {
+ addEnumerationToCollection(resources,
+ ((JEEClassLoader)exportClassLoader).findResources(name));
+ }
+ }
+ }
+ }
+ }
+ }
+*/
+
+ return resources;
+ }
+
+
+ /*
+ * Find class from contribution. If class has already been loaded, return loaded class.
+ */
+ private Class<?> findClassFromContribution(String className) throws ClassNotFoundException {
+
+ Class<?> clazz = findLoadedClass(className);
+ if (clazz == null)
+ clazz = super.findClass(className);
+ return clazz;
+
+ }
+
+ /*
+ * Find resource from contribution.
+ */
+ private URL findResourceFromContribution(String name) {
+
+ return super.findResource(name);
+ }
+
+
+ /*
+ * Add an enumeration to a Collection
+ */
+ private <T extends Object> void addEnumerationToCollection(Collection<T> collection, Enumeration<T> enumeration) {
+
+ while (enumeration.hasMoreElements())
+ collection.add(enumeration.nextElement());
+ }
+
+
+ @Override
+ public String toString() {
+ return "SCA JEE ClassLoader, parent ClassLoader: " + getParent();
+ }
+
+
+}
diff --git a/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JEEClassLoaderProvider.java b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JEEClassLoaderProvider.java
new file mode 100644
index 0000000000..73745fccef
--- /dev/null
+++ b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JEEClassLoaderProvider.java
@@ -0,0 +1,41 @@
+/*
+ * 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 org.apache.tuscany.sca.contribution.Contribution;
+import org.apache.tuscany.sca.contribution.java.ContributionClassLoaderProvider;
+import org.apache.tuscany.sca.contribution.java.impl.ContributionClassLoader;
+import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+
+/**
+ * The default implementation of the ContributionClassLoaderProvider
+ */
+public class JEEClassLoaderProvider implements ContributionClassLoaderProvider {
+
+ public JEEClassLoaderProvider(ExtensionPointRegistry registry) {
+ super();
+ }
+
+ public ClassLoader getClassLoader(Contribution contribution, ClassLoader parent) {
+ ContributionClassLoader ccl = new ContributionClassLoader(contribution, parent);
+ return new JEEClassLoader(contribution, ccl);
+ }
+
+}
diff --git a/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEIntrospectorImpl.java b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEIntrospectorImpl.java
new file mode 100644
index 0000000000..b159a21fb2
--- /dev/null
+++ b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/java/org/apache/tuscany/sca/contribution/jee/impl/JavaEEIntrospectorImpl.java
@@ -0,0 +1,420 @@
+/*
+ * 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.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URL;
+import java.net.URLConnection;
+import java.util.Map;
+
+import org.apache.openejb.config.AppModule;
+import org.apache.openejb.config.EjbModule;
+import org.apache.openejb.config.UnknownModuleTypeException;
+import org.apache.openejb.config.UnsupportedModuleTypeException;
+import org.apache.openejb.config.WebModule;
+import org.apache.openejb.jee.EjbJar;
+import org.apache.openejb.jee.EjbRef;
+import org.apache.openejb.jee.EjbRefType;
+import org.apache.openejb.jee.EjbReference;
+import org.apache.openejb.jee.EnterpriseBean;
+import org.apache.openejb.jee.EnvEntry;
+import org.apache.openejb.jee.Filter;
+import org.apache.openejb.jee.Listener;
+import org.apache.openejb.jee.MessageDrivenBean;
+import org.apache.openejb.jee.Servlet;
+import org.apache.openejb.jee.SessionBean;
+import org.apache.openejb.jee.SessionType;
+import org.apache.openejb.jee.WebApp;
+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.JavaEEIntrospector;
+import org.apache.tuscany.sca.contribution.jee.JavaEEModuleHelper;
+import org.apache.tuscany.sca.contribution.jee.WebModuleInfo;
+import org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo.EjbType;
+import org.apache.tuscany.sca.contribution.service.ContributionReadException;
+import org.apache.tuscany.sca.contribution.service.util.IOHelper;
+
+/**
+ * @version $Rev$ $Date$
+ */
+public class JavaEEIntrospectorImpl implements JavaEEIntrospector {
+
+ public WebModuleInfo introspectWebArchive(URL artifactURL) throws ContributionReadException {
+ // Create a temporary file since openejb extracts the archive to process
+ InputStream inp = null;
+ File tempFile = null;
+ try {
+ URLConnection connection = artifactURL.openConnection();
+ connection.setUseCaches(false);
+ inp = connection.getInputStream();
+ tempFile = File.createTempFile("temp", ".war");
+ FileOutputStream fout = new FileOutputStream(tempFile);
+ IOHelper.copy(inp, fout);
+ fout.close();
+ inp.close();
+ } catch (IOException e) {
+ throw new ContributionReadException(e);
+ }
+
+ JavaEEModuleHelper jmh = new JavaEEModuleHelper();
+ WebModule wm = jmh.getMetadataCompleteModules(tempFile.getAbsolutePath()).getWebModules().get(0);
+ if(!tempFile.delete()) {
+ tempFile.deleteOnExit();
+ }
+ return createWebModuleInfo(wm);
+ }
+
+ private WebModuleInfo createWebModuleInfo(WebModule webModule) {
+ WebModuleInfo wmInfo = new WebModuleInfoImpl();
+
+ WebApp webApp = webModule.getWebApp();
+ ClassLoader classLoader = webModule.getClassLoader();
+ wmInfo.setmoduleClassloader(classLoader);
+
+ // Process Remote EJB References
+ for (Map.Entry<String, EjbRef> entry : webApp.getEjbRefMap().entrySet()) {
+ EjbRef ejbRef = entry.getValue();
+ if(ejbRef.getHome() != null) {
+ // References to only EJB3 beans need to be considered.
+ // Skip the current on as it is not a reference to an EJB3 bean.
+ continue;
+ }
+ if (ejbRef.getRefType().compareTo(EjbReference.Type.REMOTE) != 0) {
+ // Only Remote EJB references need to be considered.
+ // Skip the current one as it is not a remote reference.
+ continue;
+ }
+ //FIXME: ejbRef.getEjbRefType() is null sometimes. Need a different way to figure the type.
+ if(ejbRef.getEjbRefType() != null && ejbRef.getEjbRefType().compareTo(EjbRefType.SESSION) != 0) {
+ // Only references to Session beans need to be considered.
+ // Skip the current one as it is not a Session bean.
+ continue;
+ }
+
+ try {
+ wmInfo.getEjbReferences().put(ejbRef.getEjbRefName(), createEjbReferenceInfo(ejbRef, classLoader));
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ // Process env-entries to compute properties
+ for (Map.Entry<String, EnvEntry> entry : webApp.getEnvEntryMap().entrySet()) {
+ EnvEntry envEntry = entry.getValue();
+ wmInfo.getEnvEntries().put(envEntry.getEnvEntryName(), createEnvEntryInfo(envEntry));
+ }
+
+ // Process Servlets
+ for(Servlet servlet: webApp.getServlet()) {
+ try {
+ wmInfo.getServletClasses().add(classLoader.loadClass(servlet.getServletClass()));
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ // Process Filters
+ for(Filter filter: webApp.getFilter()) {
+ try {
+ wmInfo.getFilterClasses().add(classLoader.loadClass(filter.getFilterClass()));
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ // Process Listeners
+ for(Listener listener: webApp.getListener()) {
+ try {
+ wmInfo.getListenerClasses().add(classLoader.loadClass(listener.getListenerClass()));
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ // TODO: Process JSF Managed beans
+
+ // TODO: Process JSP pages
+
+ return wmInfo;
+ }
+
+ private org.apache.tuscany.sca.contribution.jee.EnvEntryInfo createEnvEntryInfo(EnvEntry envEntry) {
+ org.apache.tuscany.sca.contribution.jee.EnvEntryInfo envEntryInfo = new org.apache.tuscany.sca.contribution.jee.EnvEntryInfo();
+ envEntryInfo.name = envEntry.getEnvEntryName();
+ envEntryInfo.type = envEntry.getEnvEntryType();
+ envEntryInfo.value = envEntry.getEnvEntryValue();
+
+ return envEntryInfo;
+ }
+
+ private org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo createEjbReferenceInfo(EjbRef ejbRef, ClassLoader classLoader) throws ClassNotFoundException {
+ org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo ejbReferenceInfo = new org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo();
+
+ ejbReferenceInfo.referenceName = ejbRef.getEjbRefName();
+ ejbReferenceInfo.referenceType = ejbRef.getRefType().compareTo(EjbReference.Type.REMOTE) == 0 ? org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo.RefType.REMOTE : ejbRef.getRefType().compareTo(EjbReference.Type.LOCAL) == 0 ? org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo.RefType.LOCAL : org.apache.tuscany.sca.contribution.jee.EjbReferenceInfo.RefType.UNKNOWN;
+ ejbReferenceInfo.businessInterface = classLoader.loadClass(ejbRef.getInterface());
+
+ ejbReferenceInfo.ejbType = EjbType.UNKNOWN;
+ if(ejbRef.getEjbRefType() != null) {
+ if(ejbRef.getEjbRefType().compareTo(EjbRefType.SESSION) == 0) {
+ ejbReferenceInfo.ejbType = EjbType.SESSION_UNKNOWN;
+ }
+ }
+
+ ejbReferenceInfo.ejbLink = ejbRef.getEjbLink();
+ ejbReferenceInfo.mappedName = ejbRef.getMappedName();
+
+ return ejbReferenceInfo;
+ }
+
+ public EjbModuleInfo introspectEjbArchive(URL artifactURL) throws ContributionReadException {
+ // Create a temporary file since openejb extracts the archive to process
+ InputStream inp = null;
+ File tempFile = null;
+ try {
+ URLConnection connection = artifactURL.openConnection();
+ connection.setUseCaches(false);
+ inp = connection.getInputStream();
+ tempFile = File.createTempFile("temp", ".jar");
+ FileOutputStream fout = new FileOutputStream(tempFile);
+ IOHelper.copy(inp, fout);
+ fout.close();
+ inp.close();
+ } catch (IOException e) {
+ throw new ContributionReadException(e);
+ }
+
+ JavaEEModuleHelper jmh = new JavaEEModuleHelper();
+ EjbModule em;
+ try {
+ em = jmh.getMetadataCompleteModules(tempFile.getAbsolutePath()).getEjbModules().get(0);
+ } catch(ContributionReadException e) {
+ if((e.getCause() instanceof UnknownModuleTypeException) ||
+ (e.getCause() instanceof UnsupportedModuleTypeException)) {
+ // Not an EJB jar
+ return null;
+ } else {
+ throw e;
+ }
+ } finally {
+ if(!tempFile.delete()) {
+ tempFile.deleteOnExit();
+ }
+ }
+ return createEjbModuleInfo(em);
+ }
+
+ private EjbModuleInfo createEjbModuleInfo(EjbModule ejbModule) {
+ EjbModuleInfo ejbModuleInfo = new EjbModuleInfoImpl();
+
+ EjbJar ejbJar = ejbModule.getEjbJar();
+ if (!ejbJar.getVersion().startsWith("3")) {
+ // Not an EJB3 module
+ // TODO: should throw an exception
+ return null;
+ }
+
+ ClassLoader classLoader = ejbModule.getClassLoader();
+ Map<String, EnterpriseBean> beansMap = ejbJar.getEnterpriseBeansByEjbName();
+ for (Map.Entry<String, EnterpriseBean> entry : beansMap.entrySet()) {
+ EnterpriseBean bean = entry.getValue();
+ EjbInfo ejbInfo = null;
+ if (bean instanceof SessionBean) {
+ SessionBean sbean = (SessionBean)bean;
+ ejbInfo = createEjbInfo(sbean, classLoader);
+ } else if (bean instanceof MessageDrivenBean) {
+ MessageDrivenBean mdbean = (MessageDrivenBean)bean;
+ ejbInfo = createEjbInfo(mdbean, classLoader);
+ } else {
+ continue;
+ }
+ if (ejbInfo != null) {
+ // Bean is an EJB3 bean
+ ejbModuleInfo.getEjbInfos().put(bean.getEjbName(), ejbInfo);
+ }
+ }
+
+ return ejbModuleInfo;
+ }
+
+ private EjbInfo createEjbInfo(MessageDrivenBean bean, ClassLoader classLoader) {
+ try {
+ if(javax.ejb.MessageDrivenBean.class.isAssignableFrom(classLoader.loadClass(bean.getEjbClass()))) {
+ // Not an EJB3 bean
+ return null;
+ }
+ } catch (ClassNotFoundException ignored) {
+ // Should not happen
+ }
+ EjbInfo ejbInfo = new EjbInfo();
+
+ ejbInfo.beanName = bean.getEjbName();
+
+ try {
+ ejbInfo.beanClass = classLoader.loadClass(bean.getEjbClass());
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+
+ ejbInfo.ejbType = org.apache.tuscany.sca.contribution.jee.EjbInfo.EjbType.MESSAGE_DRIVEN;
+
+ ejbInfo.mappedName = bean.getMappedName();
+
+ processReferencesEnvEntries(bean, classLoader, ejbInfo);
+
+ return ejbInfo;
+ }
+
+ private EjbInfo createEjbInfo(SessionBean bean, ClassLoader classLoader) {
+ if(bean.getBusinessRemote().size() == 0 && bean.getBusinessLocal().size() == 0) {
+ // Not an EJB3 Session bean
+ return null;
+ }
+ EjbInfo ejbInfo = new EjbInfo();
+
+ ejbInfo.beanName = bean.getEjbName();
+
+ try {
+ ejbInfo.beanClass = classLoader.loadClass(bean.getEjbClass());
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+
+ ejbInfo.ejbType = bean.getSessionType().equals(SessionType.STATEFUL) ? org.apache.tuscany.sca.contribution.jee.EjbInfo.EjbType.SESSION_STATEFUL : bean.getSessionType().equals(SessionType.STATELESS) ? org.apache.tuscany.sca.contribution.jee.EjbInfo.EjbType.SESSION_STATELESS : org.apache.tuscany.sca.contribution.jee.EjbInfo.EjbType.SESSION_UNKNOWN;
+
+ ejbInfo.mappedName = bean.getMappedName();
+ //FIXME: Is it ok to use beanName when mapped name is null?
+ if(ejbInfo.mappedName == null) {
+ ejbInfo.mappedName = ejbInfo.beanName;
+ }
+
+ // Process Remote Business interfaces of the SessionBean
+ for (String intfName : bean.getBusinessRemote()) {
+ try {
+ ejbInfo.businessRemote.add(classLoader.loadClass(intfName));
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ // Process Local Business interfaces of the SessionBean
+ for (String intfName : bean.getBusinessLocal()) {
+ try {
+ ejbInfo.businessLocal.add(classLoader.loadClass(intfName));
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ processReferencesEnvEntries(bean, classLoader, ejbInfo);
+
+ return ejbInfo;
+ }
+
+ private void processReferencesEnvEntries(EnterpriseBean bean, ClassLoader classLoader, EjbInfo ejbInfo) {
+ // Process Remote EJB References
+ for (Map.Entry<String, EjbRef> entry : bean.getEjbRefMap().entrySet()) {
+ EjbRef ejbRef = entry.getValue();
+ if(ejbRef.getHome() != null) {
+ // References to only EJB3 beans need to be considered.
+ // Skip the current on as it is not a reference to an EJB3 bean.
+ continue;
+ }
+ if (ejbRef.getRefType().compareTo(EjbReference.Type.REMOTE) != 0) {
+ // Only Remote EJB references need to be considered.
+ // Skip the current one as it is not a remote reference.
+ continue;
+ }
+ //FIXME: ejbRef.getEjbRefType() is null sometimes. Need a different way to figure the type.
+ if(ejbRef.getEjbRefType() != null && ejbRef.getEjbRefType().compareTo(EjbRefType.SESSION) != 0) {
+ // Only references to Session beans need to be considered.
+ // Skip the current one as it is not a Session bean.
+ continue;
+ }
+
+ try {
+ ejbInfo.ejbReferences.put(ejbRef.getEjbRefName(), createEjbReferenceInfo(ejbRef, classLoader));
+ } catch (ClassNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ // Process env-entries
+ for (Map.Entry<String, EnvEntry> entry : bean.getEnvEntryMap().entrySet()) {
+ EnvEntry envEntry = entry.getValue();
+
+ ejbInfo.envEntries.put(envEntry.getEnvEntryName(), createEnvEntryInfo(envEntry));
+ }
+ }
+
+ public JavaEEApplicationInfo introspectJeeArchive(URL artifactURL) throws ContributionReadException {
+ // Create a temporary file since openejb extracts the archive to process
+ InputStream inp = null;
+ File tempFile = null;
+ try {
+ URLConnection connection = artifactURL.openConnection();
+ connection.setUseCaches(false);
+ inp = connection.getInputStream();
+ tempFile = File.createTempFile("temp", ".ear");
+ FileOutputStream fout = new FileOutputStream(tempFile);
+ IOHelper.copy(inp, fout);
+ fout.close();
+ inp.close();
+ } catch (IOException e) {
+ throw new ContributionReadException(e);
+ }
+
+ JavaEEModuleHelper jmh = new JavaEEModuleHelper();
+ AppModule appModule = jmh.getMetadataCompleteModules(tempFile.getAbsolutePath());
+ if(!tempFile.delete()) {
+ tempFile.deleteOnExit();
+ }
+ return createJavaEEApplicationInfo(appModule);
+ }
+
+ private org.apache.tuscany.sca.contribution.jee.JavaEEApplicationInfo createJavaEEApplicationInfo(AppModule appModule) {
+ JavaEEApplicationInfo appInfo = new JavaEEApplicationInfoImpl();
+ for(EjbModule em : appModule.getEjbModules()){
+ EjbModuleInfo ejbModuleInfo = createEjbModuleInfo(em);
+ ejbModuleInfo.setModuleName(em.getModuleId());
+ appInfo.getEjbModuleInfos().put(em.getModuleId(), ejbModuleInfo);
+ }
+
+ for(WebModule wm : appModule.getWebModules()) {
+ WebModuleInfo webModuleInfo = createWebModuleInfo(wm);
+ webModuleInfo.setModuleName(wm.getModuleId());
+ appInfo.getWebModuleInfos().put(wm.getModuleId(), webModuleInfo);
+ }
+
+ return appInfo;
+ }
+}
diff --git a/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.java.ContributionClassLoaderProvider b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.java.ContributionClassLoaderProvider
new file mode 100644
index 0000000000..3f309774aa
--- /dev/null
+++ b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.java.ContributionClassLoaderProvider
@@ -0,0 +1,17 @@
+# 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.contribution.jee.impl.JEEClassLoaderProvider \ No newline at end of file
diff --git a/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.jee.JavaEEIntrospector b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.jee.JavaEEIntrospector
new file mode 100644
index 0000000000..35c1b709a5
--- /dev/null
+++ b/branches/sca-java-1.5/modules/contribution-jee-impl/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.jee.JavaEEIntrospector
@@ -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.contribution.jee.impl.JavaEEIntrospectorImpl \ No newline at end of file