servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gno...@apache.org
Subject svn commit: r593202 [2/2] - in /incubator/servicemix/branches/servicemix-4.0/jbi: ./ deployer/ deployer/src/ deployer/src/main/ deployer/src/main/java/ deployer/src/main/java/org/ deployer/src/main/java/org/apache/ deployer/src/main/java/org/apache/ser...
Date Thu, 08 Nov 2007 15:32:52 GMT
Added: incubator/servicemix/branches/servicemix-4.0/jbi/deployer/src/main/java/org/apache/servicemix/jbi/deployer/impl/Deployer.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/branches/servicemix-4.0/jbi/deployer/src/main/java/org/apache/servicemix/jbi/deployer/impl/Deployer.java?rev=593202&view=auto
==============================================================================
--- incubator/servicemix/branches/servicemix-4.0/jbi/deployer/src/main/java/org/apache/servicemix/jbi/deployer/impl/Deployer.java
(added)
+++ incubator/servicemix/branches/servicemix-4.0/jbi/deployer/src/main/java/org/apache/servicemix/jbi/deployer/impl/Deployer.java
Thu Nov  8 07:32:49 2007
@@ -0,0 +1,137 @@
+/*
+ * 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.servicemix.jbi.deployer.impl;
+
+import java.net.URL;
+import java.util.Dictionary;
+import java.util.Hashtable;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import javax.jbi.component.Component;
+
+import org.apache.servicemix.jbi.deployer.SharedLibrary;
+import org.apache.servicemix.jbi.deployer.descriptor.Descriptor;
+import org.apache.servicemix.jbi.deployer.descriptor.DescriptorFactory;
+import org.apache.servicemix.jbi.deployer.descriptor.SharedLibraryList;
+import org.apache.xbean.classloader.JarFileClassLoader;
+import org.osgi.framework.Bundle;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.BundleEvent;
+import org.osgi.framework.BundleListener;
+import org.springframework.osgi.internal.context.support.BundleDelegatingClassLoader;
+
+/**
+ * Deployer for JBI artifacts
+ *
+ */
+public class Deployer implements BundleListener {
+
+    private static final String JBI_DESCRIPTOR = "META-INF/jbi.xml";
+
+    private static final String NAME = "NAME";
+    private static final String TYPE = "TYPE";
+
+    private BundleContext context;
+
+    private Map<String, SharedLibrary> sharedLibraries;
+
+    public Deployer() {
+        sharedLibraries = new ConcurrentHashMap<String, SharedLibrary>();
+    }
+
+    public void setBundleContext(BundleContext context) {
+        this.context = context;
+    }
+
+    public void bundleChanged(BundleEvent event) {
+        try {
+            if (event.getType() == BundleEvent.INSTALLED) {
+                URL url = event.getBundle().getResource(JBI_DESCRIPTOR);
+                Descriptor descriptor = DescriptorFactory.buildDescriptor(url);
+                // TODO: check descriptor
+                if (descriptor.getComponent() != null) {
+                    // Create component class loader
+                    ClassLoader classLoader = createComponentClassLoader(descriptor.getComponent(),
event.getBundle());
+                    // Instanciate component
+                    Class clazz = classLoader.loadClass(descriptor.getComponent().getComponentClassName());
+                    Component component = (Component) clazz.newInstance();
+                    Dictionary<String, String> props = new Hashtable<String, String>();
+                    // populate props from the component meta-data
+                    props.put(NAME, descriptor.getComponent().getIdentification().getName());
+                    props.put(TYPE, descriptor.getComponent().getType());
+                    // register the component in the OSGi registry
+                    context.registerService(Component.class.getName(), component, props);
+                } else if (descriptor.getServiceAssembly() != null) {
+                    // TODO:
+                } else if (descriptor.getSharedLibrary() != null) {
+                    SharedLibraryImpl sl = new SharedLibraryImpl(descriptor.getSharedLibrary(),
event.getBundle());
+                    sharedLibraries.put(sl.getName(), sl);
+                    //context.registerService(SharedLibrary.class.getName(), sl, new Properties());
+                } else {
+                    // WARN: unhandled JBI artifact
+                }
+            }
+        } catch (Exception e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+    }
+
+    private ClassLoader createComponentClassLoader(org.apache.servicemix.jbi.deployer.descriptor.Component
component, Bundle bundle) {
+        // Create parents classloaders
+        ClassLoader[] parents;
+        if (component.getSharedLibraries() != null) {
+            parents = new ClassLoader[component.getSharedLibraries().length + 1];
+            for (int i = 0; i < component.getSharedLibraries().length; i++) {
+                parents[i + 1] = getSharedLibraryClassLoader(component.getSharedLibraries()[i]);
+            }
+        } else {
+            parents = new ClassLoader[1];
+        }
+        parents[0] = BundleDelegatingClassLoader.createBundleClassLoaderFor(bundle, null);
+
+        // Create urls
+        String[] classPathNames = component.getComponentClassPath().getPathElements();
+        URL[] urls = new URL[classPathNames.length];
+        for (int i = 0; i < classPathNames.length; i++) {
+            urls[i] = bundle.getResource(classPathNames[i]);
+            if (urls[i] == null) {
+                throw new IllegalArgumentException("SharedLibrary classpath entry not found:
'" +  classPathNames[i] + "'");
+            }
+        }
+
+        // Create classloader
+        return new JarFileClassLoader(
+                        component.getIdentification().getName(),
+                        urls,
+                        parents,
+                        component.isComponentClassLoaderDelegationSelfFirst(),
+                        new String[0],
+                        new String[] {"java.", "javax." });
+    }
+
+    private ClassLoader getSharedLibraryClassLoader(SharedLibraryList sharedLibraryList)
{
+        SharedLibrary sl = sharedLibraries.get(sharedLibraryList.getName());
+        if (sl != null) {
+            return sl.createClassLoader();
+        } else {
+            throw new IllegalStateException("SharedLibrary not installed: " + sharedLibraryList.getName());
+        }
+    }
+
+}

Added: incubator/servicemix/branches/servicemix-4.0/jbi/deployer/src/main/java/org/apache/servicemix/jbi/deployer/impl/SharedLibraryImpl.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/branches/servicemix-4.0/jbi/deployer/src/main/java/org/apache/servicemix/jbi/deployer/impl/SharedLibraryImpl.java?rev=593202&view=auto
==============================================================================
--- incubator/servicemix/branches/servicemix-4.0/jbi/deployer/src/main/java/org/apache/servicemix/jbi/deployer/impl/SharedLibraryImpl.java
(added)
+++ incubator/servicemix/branches/servicemix-4.0/jbi/deployer/src/main/java/org/apache/servicemix/jbi/deployer/impl/SharedLibraryImpl.java
Thu Nov  8 07:32:49 2007
@@ -0,0 +1,63 @@
+package org.apache.servicemix.jbi.deployer.impl;
+
+import java.io.File;
+import java.net.MalformedURLException;
+import java.net.URL;
+
+import org.apache.servicemix.jbi.deployer.SharedLibrary;
+import org.apache.servicemix.jbi.deployer.descriptor.ClassPath;
+import org.apache.xbean.classloader.JarFileClassLoader;
+import org.osgi.framework.Bundle;
+import org.springframework.osgi.internal.context.support.BundleDelegatingClassLoader;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: gnodet
+ * Date: Nov 8, 2007
+ * Time: 1:06:00 PM
+ * To change this template use File | Settings | File Templates.
+ */
+public class SharedLibraryImpl implements SharedLibrary {
+
+    private org.apache.servicemix.jbi.deployer.descriptor.SharedLibrary library;
+    private Bundle bundle;
+
+    public SharedLibraryImpl(org.apache.servicemix.jbi.deployer.descriptor.SharedLibrary
library, Bundle bundle) {
+        this.library = library;
+        this.bundle = bundle;
+    }
+
+    public String getName() {
+        return library.getIdentification().getName();
+    }
+
+    public String getDescription() {
+        return library.getIdentification().getDescription();
+    }
+
+    public String getVersion() {
+        return library.getVersion();
+    }
+
+    public ClassLoader createClassLoader() {
+        // Make the current ClassLoader the parent
+        ClassLoader parent = BundleDelegatingClassLoader.createBundleClassLoaderFor(bundle,
null);
+        boolean parentFirst = library.isParentFirstClassLoaderDelegation();
+        ClassPath cp = library.getSharedLibraryClassPath();
+        String[] classPathNames = cp.getPathElements();
+        URL[] urls = new URL[classPathNames.length];
+        for (int i = 0; i < classPathNames.length; i++) {
+            urls[i] = bundle.getResource(classPathNames[i]);
+            if (urls[i] == null) {
+                throw new IllegalArgumentException("SharedLibrary classpath entry not found:
'" +  classPathNames[i] + "'");
+            }
+        }
+        return new JarFileClassLoader(
+                        library.getIdentification().getName(),
+                        urls,
+                        parent,
+                        !parentFirst,
+                        new String[0],
+                        new String[] {"java.", "javax." });
+    }
+}

Modified: incubator/servicemix/branches/servicemix-4.0/jbi/pom.xml
URL: http://svn.apache.org/viewvc/incubator/servicemix/branches/servicemix-4.0/jbi/pom.xml?rev=593202&r1=593201&r2=593202&view=diff
==============================================================================
--- incubator/servicemix/branches/servicemix-4.0/jbi/pom.xml (original)
+++ incubator/servicemix/branches/servicemix-4.0/jbi/pom.xml Thu Nov  8 07:32:49 2007
@@ -37,6 +37,7 @@
     <modules>
         <module>api</module>
         <module>runtime</module>
+        <module>deployer</module>
         <module>osgi</module>
     </modules>
 



Mime
View raw message