+++ /dev/null
-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;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import javax.management.MBeanServer;
-import javax.management.ObjectName;
-import javax.management.StandardMBean;
-
-import org.argeo.api.cms.CmsLog;
-import org.argeo.slc.DefaultNameVersion;
-import org.argeo.slc.NameVersion;
-import org.argeo.slc.SlcException;
-import org.argeo.slc.core.execution.DefaultExecutionFlowDescriptorConverter;
-import org.argeo.slc.deploy.Module;
-import org.argeo.slc.deploy.ModuleDescriptor;
-import org.argeo.slc.execution.ExecutionContext;
-import org.argeo.slc.execution.ExecutionFlow;
-import org.argeo.slc.execution.ExecutionFlowDescriptor;
-import org.argeo.slc.execution.ExecutionFlowDescriptorConverter;
-import org.argeo.slc.execution.ExecutionModuleDescriptor;
-import org.argeo.slc.execution.ExecutionModulesListener;
-import org.argeo.slc.execution.RealizedFlow;
-import org.argeo.slc.runtime.AbstractExecutionModulesManager;
-import org.eclipse.gemini.blueprint.service.importer.OsgiServiceLifecycleListener;
-import org.osgi.framework.Bundle;
-import org.osgi.framework.BundleEvent;
-import org.osgi.framework.BundleException;
-import org.osgi.framework.BundleListener;
-import org.osgi.framework.Constants;
-import org.osgi.framework.launch.Framework;
-import org.springframework.context.ApplicationContext;
-
-/** Execution modules manager implementation based on an OSGi runtime. */
-public class OsgiExecutionModulesManager extends
- AbstractExecutionModulesManager implements
- OsgiServiceLifecycleListener, BundleListener {
-
- private final static CmsLog log = CmsLog
- .getLog(OsgiExecutionModulesManager.class);
-
- private BundlesManager bundlesManager;
- private Map<OsgiBundle, ExecutionContext> executionContexts = new HashMap<OsgiBundle, ExecutionContext>();
- private Map<OsgiBundle, ExecutionFlowDescriptorConverter> executionFlowDescriptorConverters = new HashMap<OsgiBundle, ExecutionFlowDescriptorConverter>();
- private Map<OsgiBundle, Set<ExecutionFlow>> executionFlows = new HashMap<OsgiBundle, Set<ExecutionFlow>>();
- private ExecutionFlowDescriptorConverter defaultDescriptorConverter = new DefaultExecutionFlowDescriptorConverter();
-
- private List<ExecutionModulesListener> executionModulesListeners = new ArrayList<ExecutionModulesListener>();
-
- private Boolean registerFlowsToJmx = false;
-
- public void init() throws Exception {
- bundlesManager.getBundleContext().addBundleListener(this);
-
- 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() {
- executeFlowAndExit(module, null, flow);
- }
- }.start();
- }
- }
-
- public void destroy() {
- bundlesManager.getBundleContext().removeBundleListener(this);
- }
-
- /** Executes a single flow and <b>stops the JVM</b> */
- protected void executeFlowAndExit(final String module,
- final String version, final String flow) {
- if (log.isDebugEnabled())
- log.debug("Launch unique flow " + flow + " from module " + module);
- try {
- OsgiBundle osgiBundle = bundlesManager.findFromPattern(module);
- if (osgiBundle == null)
- throw new SlcException("No OSGi bundle found for " + module);
- // Bundle moduleBundle =
- // bundlesManager.findRelatedBundle(osgiBundle);
- start(osgiBundle);
-
- 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);
- }
- }
- }
-
- // public void startExectionModule(String moduleName, String moduleVersion)
- // {
- // try {
- // ServiceReference[] sr = bundlesManager.getServiceRefSynchronous(
- // ApplicationContext.class.getName(),
- // "org.springframework.context.service.name=" + moduleName);
- // // bundlesManager.startSynchronous(moduleBundle);
- // if (sr == null || sr.length == 0)
- // throw new SlcException(
- // "Cannot find execution module application context "
- // + moduleName);
- // } catch (InvalidSyntaxException e) {
- // throw new SlcException("Cannot start exeuction module "
- // + moduleName, e);
- // }
- // }
-
- public synchronized ExecutionModuleDescriptor getExecutionModuleDescriptor(
- String moduleName, String version) {
- ExecutionModuleDescriptor md = new ExecutionModuleDescriptor();
- OsgiBundle osgiBundle = null;
- DefaultNameVersion nameVersion = new DefaultNameVersion(moduleName,
- version);
- bundles: for (Iterator<OsgiBundle> iterator = executionContexts
- .keySet().iterator(); iterator.hasNext();) {
- OsgiBundle ob = iterator.next();
- if (nameVersion.getVersion() != null) {
- if (ob.equals(nameVersion)) {
- osgiBundle = ob;
- break bundles;
- }
- } else {
- if (ob.getName().equals(nameVersion.getName())) {
- osgiBundle = ob;
- break bundles;
- }
- }
- }
- if (osgiBundle == null)
- throw new SlcException("No execution module registered for "
- + nameVersion);
- md.setName(osgiBundle.getName());
- md.setVersion(osgiBundle.getVersion());
- md.setTitle(osgiBundle.getTitle());
- md.setDescription(osgiBundle.getDescription());
-
- ExecutionFlowDescriptorConverter executionFlowDescriptorConverter = getExecutionFlowDescriptorConverter(
- moduleName, version);
- if (executionFlowDescriptorConverter == null)
- throw new SlcException("No flow converter found.");
- executionFlowDescriptorConverter.addFlowsToDescriptor(md,
- listFlows(moduleName, version));
- return md;
- }
-
- public synchronized List<ExecutionModuleDescriptor> listExecutionModules() {
- List<ExecutionModuleDescriptor> descriptors = new ArrayList<ExecutionModuleDescriptor>();
-
- for (Iterator<OsgiBundle> iterator = executionContexts.keySet()
- .iterator(); iterator.hasNext();) {
- OsgiBundle osgiBundle = iterator.next();
- ExecutionModuleDescriptor md = new ExecutionModuleDescriptor();
- setMetadataFromBundle(md,
- bundlesManager.findRelatedBundle(osgiBundle));
- descriptors.add(md);
- }
- return descriptors;
- }
-
- protected synchronized Map<String, ExecutionFlow> listFlows(
- String moduleName, String moduleVersion) {
-
- Map<String, ExecutionFlow> flows = new HashMap<String, ExecutionFlow>();
- OsgiBundle key = bundlesManager.findRelatedBundle(moduleName,
- moduleVersion);
- if (!executionFlows.containsKey(key))
- return flows;
- Set<ExecutionFlow> flowsT = executionFlows.get(key);
- for (ExecutionFlow flow : flowsT)
- flows.put(flow.getName(), flow);
- return flows;
- }
-
- protected ExecutionFlow findExecutionFlow(String moduleName,
- String moduleVersion, String flowName) {
- String filter = moduleVersion == null || moduleVersion.equals("0.0.0") ? "(&(Bundle-SymbolicName="
- + moduleName
- + ")(org.eclipse.gemini.blueprint.bean.name="
- + flowName + "))"
- : "(&(Bundle-SymbolicName=" + moduleName + ")(Bundle-Version="
- + moduleVersion
- + ")(org.eclipse.gemini.blueprint.bean.name="
- + flowName + "))";
- return bundlesManager.getSingleServiceStrict(ExecutionFlow.class,
- filter, true);
- }
-
- protected ExecutionContext findExecutionContext(String moduleName,
- String moduleVersion) {
- String filter = moduleFilter(moduleName, moduleVersion);
- return bundlesManager.getSingleServiceStrict(ExecutionContext.class,
- filter, true);
- }
-
- protected ExecutionFlowDescriptorConverter findExecutionFlowDescriptorConverter(
- String moduleName, String moduleVersion) {
- String filter = moduleFilter(moduleName, moduleVersion);
- return bundlesManager.getSingleService(
- ExecutionFlowDescriptorConverter.class, filter, false);
- }
-
- /** Only based on symbolic name if version is null or "0.0.0" */
- protected String moduleFilter(String moduleName, String moduleVersion) {
- return moduleVersion == null || moduleVersion.equals("0.0.0") ? "(Bundle-SymbolicName="
- + moduleName + ")"
- : "(&(Bundle-SymbolicName=" + moduleName + ")(Bundle-Version="
- + moduleVersion + "))";
-
- }
-
- /**
- * Builds a minimal realized flow, based on the provided information
- * (typically from the command line).
- *
- * @param module
- * a bundle id, or a pattern contained in a bundle symbolic name
- * @param module
- * the execution flow name
- * @return a minimal realized flow, to be used in an execution
- */
- public RealizedFlow findRealizedFlow(String module, String executionName) {
- // First check whether we have a bundleId
- Long bundleId = null;
- try {
- bundleId = Long.parseLong(module);
- } catch (NumberFormatException e) {
- // silent
- }
-
- // Look for bundle names containing pattern
- OsgiBundle bundle = null;
- if (bundleId != null) {
- bundle = bundlesManager.getBundle(bundleId);
- } else {
- bundle = bundlesManager.findFromPattern(module);
- }
-
- if (bundle != null) {
- RealizedFlow launch = new RealizedFlow();
- launch.setModuleName(bundle.getName());
- launch.setModuleVersion(bundle.getVersion());
- ExecutionFlowDescriptor descriptor = new ExecutionFlowDescriptor();
- descriptor.setName(executionName);
- launch.setFlowDescriptor(descriptor);
- return launch;
- } else {
- log.warn("Could not find any execution module matching these requirements.");
- return null;
- }
- }
-
- public void upgrade(NameVersion nameVersion) {
- OsgiBundle osgiBundle = new OsgiBundle(nameVersion);
- bundlesManager.upgradeSynchronous(osgiBundle);
- }
-
- protected synchronized ExecutionFlowDescriptorConverter getExecutionFlowDescriptorConverter(
- String moduleName, String moduleVersion) {
- return findExecutionFlowDescriptorConverter(moduleName, moduleVersion);
- // OsgiBundle osgiBundle = new OsgiBundle(moduleName, moduleVersion);
- // return getExecutionFlowDescriptorConverter(osgiBundle);
- }
-
- protected synchronized ExecutionFlowDescriptorConverter getExecutionFlowDescriptorConverter(
- OsgiBundle osgiBundle) {
- if (executionFlowDescriptorConverters.containsKey(osgiBundle))
- return executionFlowDescriptorConverters.get(osgiBundle);
- else
- return defaultDescriptorConverter;
- }
-
- public ModuleDescriptor getModuleDescriptor(String moduleName,
- String version) {
- return getExecutionModuleDescriptor(moduleName, version);
- }
-
- public List<ModuleDescriptor> listModules() {
- Bundle[] bundles = bundlesManager.getBundleContext().getBundles();
- List<ModuleDescriptor> lst = new ArrayList<ModuleDescriptor>();
- for (Bundle bundle : bundles) {
- ModuleDescriptor moduleDescriptor = new ModuleDescriptor();
- setMetadataFromBundle(moduleDescriptor, bundle);
- lst.add(moduleDescriptor);
- }
- return lst;
- }
-
- public void start(NameVersion nameVersion) {
- try {
- Bundle bundle = bundlesManager.findRelatedBundle(new OsgiBundle(
- nameVersion));
- if (bundle == null)
- throw new SlcException("Could not find bundle for "
- + nameVersion);
-
- bundlesManager.startSynchronous(bundle);
- if (isSpringInstrumented(bundle)) {
- // Wait for Spring application context to be ready
- String filter = "(Bundle-SymbolicName="
- + bundle.getSymbolicName() + ")";
- try {
- bundlesManager.getServiceRefSynchronous(
- ApplicationContext.class, filter);
- } catch (Exception e) {
- // stop if application context not found
- bundle.stop();
- throw e;
- }
- }
- } catch (Exception e) {
- throw new SlcException("Cannot start " + nameVersion, e);
- }
- }
-
- /** Do it calmly in order to avoid NPE */
- private Boolean isSpringInstrumented(Bundle bundle) {
- Dictionary<?, ?> headers = bundle.getHeaders();
- if (headers != null && headers.get("Spring-Context") != null)
- return true;
- Enumeration<?> springEntryPaths = bundle
- .getEntryPaths("/META-INF/spring");
- if (springEntryPaths != null && springEntryPaths.hasMoreElements())
- return true;
- return false;
- }
-
- public void stop(NameVersion nameVersion) {
- try {
- Bundle bundle = bundlesManager.findRelatedBundle(new OsgiBundle(
- nameVersion));
- bundlesManager.stopSynchronous(bundle);
- } catch (BundleException e) {
- throw new SlcException("Cannot stop " + nameVersion, e);
- }
- }
-
- protected void setMetadataFromBundle(ModuleDescriptor md, Bundle bundle) {
- Bundle bdl = bundle;
- if (bdl == null) {
- if (md.getName() == null || md.getVersion() == null)
- throw new SlcException("Name and version not available.");
-
- Bundle[] bundles = bundlesManager.getBundleContext().getBundles();
- for (Bundle b : bundles) {
- if (b.getSymbolicName().equals(md.getName())
- && md.getVersion().equals(
- getHeaderSafe(b, Constants.BUNDLE_VERSION))) {
- bdl = b;
- break;
- }
- }
-
- }
-
- if (bdl == null)
- throw new SlcException("Cannot find bundle.");
-
- md.setName(bdl.getSymbolicName());
- 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) {
- Object obj = bundle.getHeaders().get(key);
- if (obj == null)
- return null;
- else
- return obj.toString();
- }
-
- /*
- * REGISTRATION
- */
-
- /** Registers an execution context. */
- public synchronized void register(ExecutionContext executionContext,
- Map<String, String> properties) {
- OsgiBundle osgiBundle = asOsgiBundle(properties);
- Bundle bundle = bundlesManager.findRelatedBundle(osgiBundle);
- osgiBundle.setTitle(getHeaderSafe(bundle, Constants.BUNDLE_NAME));
- osgiBundle.setDescription(getHeaderSafe(bundle,
- Constants.BUNDLE_DESCRIPTION));
- executionContexts.put(osgiBundle, executionContext);
- if (log.isTraceEnabled())
- log.trace("Registered execution context from " + osgiBundle);
- // Notify
- ModuleDescriptor md = osgiBundle.getModuleDescriptor();
- md.setStarted(true);
- for (ExecutionModulesListener listener : executionModulesListeners)
- listener.executionModuleAdded(md);
- }
-
- /** Unregisters an execution context. */
- public synchronized void unregister(ExecutionContext executionContext,
- Map<String, String> properties) {
- // FIXME why are properties null?
- if (properties == null)
- return;
- OsgiBundle osgiBundle = asOsgiBundle(properties);
- if (executionContexts.containsKey(osgiBundle)) {
- executionContexts.remove(osgiBundle);
- if (log.isTraceEnabled())
- log.trace("Removed execution context from " + osgiBundle);
- // Notify
- ModuleDescriptor md = osgiBundle.getModuleDescriptor();
- md.setStarted(false);
- for (ExecutionModulesListener listener : executionModulesListeners)
- listener.executionModuleRemoved(md);
- }
- }
-
- /** Registers an execution flow. */
- public synchronized void register(ExecutionFlow executionFlow,
- Map<String, String> properties) {
- OsgiBundle osgiBundle = asOsgiBundle(properties);
- if (!executionFlows.containsKey(osgiBundle)) {
- executionFlows.put(osgiBundle, new HashSet<ExecutionFlow>());
- }
- executionFlows.get(osgiBundle).add(executionFlow);
- if (log.isTraceEnabled())
- log.trace("Registered " + executionFlow + " from " + osgiBundle);
-
- // notifications
- if (registerFlowsToJmx)
- registerMBean(osgiBundle, executionFlow);
- ExecutionFlowDescriptorConverter efdc = getExecutionFlowDescriptorConverter(osgiBundle);
- for (ExecutionModulesListener listener : executionModulesListeners)
- listener.executionFlowAdded(osgiBundle.getModuleDescriptor(),
- efdc.getExecutionFlowDescriptor(executionFlow));
- }
-
- /** Unregisters an execution flow. */
- public synchronized void unregister(ExecutionFlow executionFlow,
- Map<String, String> properties) {
- // FIXME why are properties null?
- if (properties == null)
- return;
- OsgiBundle osgiBundle = asOsgiBundle(properties);
- if (executionFlows.containsKey(osgiBundle)) {
- Set<ExecutionFlow> flows = executionFlows.get(osgiBundle);
- flows.remove(executionFlow);
- if (log.isTraceEnabled())
- log.trace("Removed " + executionFlow + " from " + osgiBundle);
- if (flows.size() == 0) {
- executionFlows.remove(osgiBundle);
- if (log.isTraceEnabled())
- log.trace("Removed flows set from " + osgiBundle);
- }
-
- // notifications
- if (registerFlowsToJmx)
- unregisterMBean(osgiBundle, executionFlow);
- ExecutionFlowDescriptorConverter efdc = getExecutionFlowDescriptorConverter(osgiBundle);
- for (ExecutionModulesListener listener : executionModulesListeners)
- listener.executionFlowRemoved(osgiBundle.getModuleDescriptor(),
- efdc.getExecutionFlowDescriptor(executionFlow));
- }
- }
-
- /** Registers an execution module listener. */
- public synchronized void register(
- ExecutionModulesListener executionModulesListener,
- Map<String, String> properties) {
- // sync with current state
- for (OsgiBundle osgiBundle : executionContexts.keySet()) {
- executionModulesListener.executionModuleAdded(osgiBundle
- .getModuleDescriptor());
- }
- for (OsgiBundle osgiBundle : executionFlows.keySet()) {
- ExecutionFlowDescriptorConverter efdc = getExecutionFlowDescriptorConverter(osgiBundle);
- for (ExecutionFlow executionFlow : executionFlows.get(osgiBundle))
- executionModulesListener.executionFlowAdded(
- osgiBundle.getModuleDescriptor(),
- efdc.getExecutionFlowDescriptor(executionFlow));
- }
- executionModulesListeners.add(executionModulesListener);
- }
-
- /** Unregisters an execution module listener. */
- public synchronized void unregister(
- ExecutionModulesListener executionModulesListener,
- Map<String, String> properties) {
- executionModulesListeners.remove(executionModulesListener);
- }
-
- /*
- * INTERFACE IMPLEMENTATIONS
- */
-
- public void bundleChanged(BundleEvent evt) {
- Bundle bundle = evt.getBundle();
- if (bundle.getHeaders().get(
- ExecutionModuleDescriptor.SLC_EXECUTION_MODULE) != null) {
- OsgiBundle osgiBundle = new OsgiBundle(bundle);
- if (evt.getType() == BundleEvent.INSTALLED)
- for (ExecutionModulesListener listener : executionModulesListeners)
- listener.executionModuleAdded(osgiBundle
- .getModuleDescriptor());
- else if (evt.getType() == BundleEvent.UNINSTALLED)
- for (ExecutionModulesListener listener : executionModulesListeners)
- listener.executionModuleRemoved(osgiBundle
- .getModuleDescriptor());
- }
-
- }
-
- @SuppressWarnings({ "rawtypes" })
- public synchronized void bind(Object service, Map properties)
- throws Exception {
- if (service instanceof ExecutionFlowDescriptorConverter) {
- ExecutionFlowDescriptorConverter executionFlowDescriptorConverter = (ExecutionFlowDescriptorConverter) service;
- OsgiBundle osgiBundle = asOsgiBundle(properties);
- executionFlowDescriptorConverters.put(osgiBundle,
- executionFlowDescriptorConverter);
- if (log.isTraceEnabled())
- log.debug("Registered execution flow descriptor converter from "
- + osgiBundle);
- } else {
- // ignore
- }
- }
-
- @SuppressWarnings("rawtypes")
- public synchronized void unbind(Object service, Map properties)
- throws Exception {
- if (service instanceof ExecutionFlowDescriptorConverter) {
- OsgiBundle osgiBundle = asOsgiBundle(properties);
- if (executionFlowDescriptorConverters.containsKey(osgiBundle)) {
- executionFlowDescriptorConverters.remove(osgiBundle);
- if (log.isTraceEnabled())
- log.debug("Removed execution flow descriptor converter from "
- + osgiBundle);
- }
- } else {
- // ignore
- }
- }
-
- /*
- * JMX
- */
- protected MBeanServer getMBeanServer() {
- return ManagementFactory.getPlatformMBeanServer();
- }
-
- public void registerMBean(Module module, ExecutionFlow executionFlow) {
- try {
- StandardMBean mbean = new StandardMBean(executionFlow,
- ExecutionFlow.class);
- getMBeanServer().registerMBean(mbean,
- flowMBeanName(module, executionFlow));
- } catch (Exception e) {
- String msg = "Cannot register execution flow " + executionFlow
- + " as mbean";
- throw new SlcException(msg, e);
- }
- }
-
- public void unregisterMBean(Module module, ExecutionFlow executionFlow) {
- try {
- getMBeanServer().unregisterMBean(
- flowMBeanName(module, executionFlow));
- } catch (Exception e) {
- String msg = "Cannot unregister execution flow " + executionFlow
- + " as mbean";
- throw new SlcException(msg, e);
- }
- }
-
- protected ObjectName flowMBeanName(Module module,
- ExecutionFlow executionFlow) {
- String executionModulesPrefix = "SLCExecutionModules";
- // String path = executionFlow.getPath();
- String name = executionFlow.getName();
- // if (path == null && name.indexOf('/') >= 0) {
- // path = name.substring(0, name.lastIndexOf('/'));
- // name = name.substring(name.lastIndexOf('/'));
- // }
-
- StringBuffer buf = new StringBuffer(executionModulesPrefix + ":"
- + "module=" + module.getName() + " [" + module.getVersion()
- + "],");
-
- // if (path != null && !path.equals("")) {
- // int depth = 0;
- // for (String token : path.split("/")) {
- // if (!token.equals("")) {
- // buf.append("path").append(depth).append('=');
- // // in order to have directories first
- // buf.append('/');
- // buf.append(token).append(',');
- // depth++;
- // }
- // }
- // }
- buf.append("name=").append(name);
- try {
- return new ObjectName(buf.toString());
- } catch (Exception e) {
- throw new SlcException("Cannot generate object name based on "
- + buf, e);
- }
- }
-
- /*
- * UTILITIES
- */
- @SuppressWarnings("rawtypes")
- private OsgiBundle asOsgiBundle(Map properties) {
- String bundleSymbolicName = checkAndGet(Constants.BUNDLE_SYMBOLICNAME,
- properties);
- String bundleVersion = checkAndGet(Constants.BUNDLE_VERSION, properties);
- return new OsgiBundle(bundleSymbolicName, bundleVersion);
- }
-
- @SuppressWarnings("rawtypes")
- private String checkAndGet(Object key, Map properties) {
- if (!properties.containsKey(key) || properties.get(key) == null)
- throw new SlcException(key + " not set in " + properties);
- else
- return properties.get(key).toString();
- }
-
- public void setBundlesManager(BundlesManager bundlesManager) {
- this.bundlesManager = bundlesManager;
- }
-
- public void setDefaultDescriptorConverter(
- ExecutionFlowDescriptorConverter defaultDescriptorConverter) {
- this.defaultDescriptorConverter = defaultDescriptorConverter;
- }
-
- public void setRegisterFlowsToJmx(Boolean registerFlowsToJmx) {
- this.registerFlowsToJmx = registerFlowsToJmx;
- }
-
-}
projects / gpl / argeo-slc.git / blobdiff