X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.osgi%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fosgi%2FOsgiExecutionModulesManager.java;h=15a3f0de9bbcb27b56d75ad22fdb558e1975ce0a;hb=699640c58cc0578beebfc3edd00dac9eed65ee0b;hp=6625ebd3b53fbacbc79c31360328111f1bc1fff8;hpb=ac38932aab09592c1ec0af26c26899536dff284f;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.support.osgi/src/main/java/org/argeo/slc/osgi/OsgiExecutionModulesManager.java b/runtime/org.argeo.slc.support.osgi/src/main/java/org/argeo/slc/osgi/OsgiExecutionModulesManager.java
index 6625ebd3b..15a3f0de9 100644
--- a/runtime/org.argeo.slc.support.osgi/src/main/java/org/argeo/slc/osgi/OsgiExecutionModulesManager.java
+++ b/runtime/org.argeo.slc.support.osgi/src/main/java/org/argeo/slc/osgi/OsgiExecutionModulesManager.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2010 Mathieu Baudier <mbaudier@argeo.org>
+ * Copyright (C) 2007-2012 Mathieu Baudier
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -13,11 +13,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.argeo.slc.osgi;
 
 import java.lang.management.ManagementFactory;
 import java.util.ArrayList;
+import java.util.Dictionary;
+import java.util.Enumeration;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.Iterator;
@@ -48,6 +49,8 @@ import org.argeo.slc.process.RealizedFlow;
 import org.osgi.framework.Bundle;
 import org.osgi.framework.BundleException;
 import org.osgi.framework.Constants;
+import org.osgi.framework.launch.Framework;
+import org.springframework.context.ApplicationContext;
 import org.springframework.osgi.service.importer.OsgiServiceLifecycleListener;
 
 /** Execution modules manager implementation based on an OSGi runtime. */
@@ -67,6 +70,58 @@ public class OsgiExecutionModulesManager extends
 
 	private Boolean registerFlowsToJmx = true;
 
+	public void init() throws Exception {
+		final String module = System.getProperty(UNIQUE_LAUNCH_MODULE_PROPERTY);
+		final String flow = System.getProperty(UNIQUE_LAUNCH_FLOW_PROPERTY);
+		if (module != null) {
+			// launch a flow and stops
+			new Thread("Unique Flow") {
+				@Override
+				public void run() {
+					if (log.isDebugEnabled())
+						log.debug("Launch unique flow " + flow
+								+ " from module " + module);
+					try {
+						OsgiBundle osgiBundle = bundlesManager
+								.findFromPattern(module);
+						Bundle moduleBundle = bundlesManager
+								.findRelatedBundle(osgiBundle);
+						bundlesManager.startSynchronous(moduleBundle);
+						RealizedFlow lastLaunch = findRealizedFlow(module, flow);
+						if (lastLaunch == null)
+							throw new SlcException("Cannot find launch for "
+									+ module + " " + flow);
+						execute(lastLaunch);
+					} catch (Exception e) {
+						log.error("Error in unique flow " + flow
+								+ " from module " + module, e);
+					} finally {
+						if (log.isDebugEnabled())
+							log.debug("Shutdown OSGi runtime...");
+						Framework framework = (Framework) bundlesManager
+								.getBundleContext().getBundle(0);
+						try {
+							// shutdown framework
+							framework.stop();
+							// wait 1 min for shutdown
+							framework.waitForStop(60 * 1000);
+							// close VM
+							System.exit(0);
+						} catch (Exception e) {
+							e.printStackTrace();
+							System.exit(1);
+						}
+					}
+				}
+			}.start();
+		}
+
+	}
+
+	public void destroy() {
+
+	}
+
 	public synchronized ExecutionModuleDescriptor getExecutionModuleDescriptor(
 			String moduleName, String version) {
 		ExecutionModuleDescriptor md = new ExecutionModuleDescriptor();
@@ -129,7 +184,7 @@ public class OsgiExecutionModulesManager extends
 		String filter = "(&(Bundle-SymbolicName=" + moduleName
 				+ ")(org.springframework.osgi.bean.name=" + flowName + "))";
 		return bundlesManager.getSingleServiceStrict(ExecutionFlow.class,
-				filter);
+				filter, true);
 	}
 
 	protected ExecutionContext findExecutionContext(String moduleName,
@@ -137,16 +192,15 @@ public class OsgiExecutionModulesManager extends
 		String filter = "(&(Bundle-SymbolicName=" + moduleName
 				+ ")(Bundle-Version=" + moduleVersion + "))";
 		return bundlesManager.getSingleServiceStrict(ExecutionContext.class,
-				filter);
+				filter, true);
 	}
 
 	protected ExecutionFlowDescriptorConverter findExecutionFlowDescriptorConverter(
 			String moduleName, String moduleVersion) {
-
 		String filter = "(&(Bundle-SymbolicName=" + moduleName
 				+ ")(Bundle-Version=" + moduleVersion + "))";
 		return bundlesManager.getSingleService(
-				ExecutionFlowDescriptorConverter.class, filter);
+				ExecutionFlowDescriptorConverter.class, filter, false);
 	}
 
 	/**
@@ -230,7 +284,23 @@ public class OsgiExecutionModulesManager extends
 			Bundle bundle = bundlesManager.findRelatedBundle(new OsgiBundle(
 					nameVersion));
 			bundlesManager.startSynchronous(bundle);
-		} catch (BundleException e) {
+			boolean isSpringInstrumented = bundle.getEntryPaths(
+					"/META-INF/spring").hasMoreElements()
+					|| bundle.getHeaders().get("Spring-Context") == null;
+			if (isSpringInstrumented) {
+				// Wait for Spring application context to be ready
+				String filter = "(Bundle-SymbolicName="
+						+ bundle.getSymbolicName() + ")";
+				try {
+					bundlesManager.getServiceRefSynchronous(
+							ApplicationContext.class.getName(), filter);
+				} catch (Exception e) {
+					// stop if application context not found
+					bundle.stop();
+					throw e;
+				}
+			}
+		} catch (Exception e) {
 			throw new SlcException("Cannot start " + nameVersion, e);
 		}
 	}
@@ -270,6 +340,23 @@ public class OsgiExecutionModulesManager extends
 		md.setVersion(getHeaderSafe(bdl, Constants.BUNDLE_VERSION));
 		md.setTitle(getHeaderSafe(bdl, Constants.BUNDLE_NAME));
 		md.setDescription(getHeaderSafe(bdl, Constants.BUNDLE_DESCRIPTION));
+
+		// copy manifets header to meta data
+		Dictionary<?, ?> headers = bundle.getHeaders();
+		Enumeration<?> keys = headers.keys();
+		while (keys.hasMoreElements()) {
+			Object key = keys.nextElement();
+			Object value = headers.get(key);
+			if (value != null)
+				md.getMetadata().put(key.toString(), value.toString());
+		}
+
+		// check if started
+		if (bundle.getState() == Bundle.ACTIVE
+				|| bundle.getState() == Bundle.STARTING)
+			md.setStarted(true);
+		else
+			md.setStarted(false);
 	}
 
 	private String getHeaderSafe(Bundle bundle, Object key) {
@@ -456,7 +543,7 @@ public class OsgiExecutionModulesManager extends
 		String path = executionFlow.getPath();
 		String name = executionFlow.getName();
 		if (path == null && name.indexOf('/') >= 0) {
-			path = name.substring(0, name.lastIndexOf('/') - 1);
+			path = name.substring(0, name.lastIndexOf('/'));
 			name = name.substring(name.lastIndexOf('/'));
 		}