org.argeo.slc.osgi

Class OsgiExecutionModulesManager

java.lang.Object

org.argeo.slc.core.execution.AbstractExecutionModulesManager

org.argeo.slc.osgi.OsgiExecutionModulesManager

All Implemented Interfaces:

java.util.EventListener, ModulesManager, ExecutionModulesManager, org.eclipse.gemini.blueprint.service.importer.OsgiServiceLifecycleListener, BundleListener

public class OsgiExecutionModulesManager
extends AbstractExecutionModulesManager
implements org.eclipse.gemini.blueprint.service.importer.OsgiServiceLifecycleListener, BundleListener

Execution modules manager implementation based on an OSGi runtime.

Field Summary

Fields inherited from interface org.argeo.slc.execution.ExecutionModulesManager

SLC_PROCESS_ID, UNIQUE_LAUNCH_FLOW_PROPERTY, UNIQUE_LAUNCH_MODULE_PROPERTY

Constructor Summary

Constructors

Constructor and Description
OsgiExecutionModulesManager()

Method Summary

Modifier and Type	Method and Description
void	bind(java.lang.Object service, java.util.Map properties)
void	bundleChanged(BundleEvent evt)
void	destroy()
protected void	executeFlowAndExit(java.lang.String module, java.lang.String version, java.lang.String flow) Executes a single flow and stops the JVM
protected ExecutionContext	findExecutionContext(java.lang.String moduleName, java.lang.String moduleVersion)
protected ExecutionFlow	findExecutionFlow(java.lang.String moduleName, java.lang.String moduleVersion, java.lang.String flowName)
protected ExecutionFlowDescriptorConverter	findExecutionFlowDescriptorConverter(java.lang.String moduleName, java.lang.String moduleVersion)
RealizedFlow	findRealizedFlow(java.lang.String module, java.lang.String executionName) Builds a minimal realized flow, based on the provided information (typically from the command line).
protected javax.management.ObjectName	flowMBeanName(Module module, ExecutionFlow executionFlow)
protected ExecutionFlowDescriptorConverter	getExecutionFlowDescriptorConverter(OsgiBundle osgiBundle)
protected ExecutionFlowDescriptorConverter	getExecutionFlowDescriptorConverter(java.lang.String moduleName, java.lang.String moduleVersion)
ExecutionModuleDescriptor	getExecutionModuleDescriptor(java.lang.String moduleName, java.lang.String version)
protected javax.management.MBeanServer	getMBeanServer()
ModuleDescriptor	getModuleDescriptor(java.lang.String moduleName, java.lang.String version)
void	init()
java.util.List<ExecutionModuleDescriptor>	listExecutionModules()
protected java.util.Map<java.lang.String,ExecutionFlow>	listFlows(java.lang.String moduleName, java.lang.String moduleVersion)
java.util.List<ModuleDescriptor>	listModules()
protected java.lang.String	moduleFilter(java.lang.String moduleName, java.lang.String moduleVersion) Only based on symbolic name if version is null or "0.0.0"
void	register(ExecutionContext executionContext, java.util.Map<java.lang.String,java.lang.String> properties) Registers an execution context.
void	register(ExecutionFlow executionFlow, java.util.Map<java.lang.String,java.lang.String> properties) Registers an execution flow.
void	register(ExecutionModulesListener executionModulesListener, java.util.Map<java.lang.String,java.lang.String> properties) Registers an execution module listener.
void	registerMBean(Module module, ExecutionFlow executionFlow)
void	setBundlesManager(BundlesManager bundlesManager)
void	setDefaultDescriptorConverter(ExecutionFlowDescriptorConverter defaultDescriptorConverter)
protected void	setMetadataFromBundle(ModuleDescriptor md, Bundle bundle)
void	setRegisterFlowsToJmx(java.lang.Boolean registerFlowsToJmx)
void	start(NameVersion nameVersion) Starts the module
void	stop(NameVersion nameVersion) Stops the module
void	unbind(java.lang.Object service, java.util.Map properties)
void	unregister(ExecutionContext executionContext, java.util.Map<java.lang.String,java.lang.String> properties) Unregisters an execution context.
void	unregister(ExecutionFlow executionFlow, java.util.Map<java.lang.String,java.lang.String> properties) Unregisters an execution flow.
void	unregister(ExecutionModulesListener executionModulesListener, java.util.Map<java.lang.String,java.lang.String> properties) Unregisters an execution module listener.
void	unregisterMBean(Module module, ExecutionFlow executionFlow)
void	upgrade(NameVersion nameVersion) Synchronously upgrades the module referenced by this name version

Methods inherited from class org.argeo.slc.core.execution.AbstractExecutionModulesManager

execute

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OsgiExecutionModulesManager

public OsgiExecutionModulesManager()

Method Detail

init

public void init()
          throws java.lang.Exception

Throws:

java.lang.Exception

destroy

public void destroy()

executeFlowAndExit

protected void executeFlowAndExit(java.lang.String module,
                                  java.lang.String version,
                                  java.lang.String flow)

Executes a single flow and stops the JVM

getExecutionModuleDescriptor

public ExecutionModuleDescriptor getExecutionModuleDescriptor(java.lang.String moduleName,
                                                              java.lang.String version)

Specified by:

getExecutionModuleDescriptor in interface ExecutionModulesManager

Returns:

a full fledged module descriptor.

listExecutionModules

public java.util.List<ExecutionModuleDescriptor> listExecutionModules()

Specified by:

listExecutionModules in interface ExecutionModulesManager

Returns:

a list of minimal execution module descriptors (only the module meta data, not the flows)

listFlows

protected java.util.Map<java.lang.String,ExecutionFlow> listFlows(java.lang.String moduleName,
                                                                  java.lang.String moduleVersion)

findExecutionFlow

protected ExecutionFlow findExecutionFlow(java.lang.String moduleName,
                                          java.lang.String moduleVersion,
                                          java.lang.String flowName)

Specified by:

findExecutionFlow in class AbstractExecutionModulesManager

findExecutionContext

protected ExecutionContext findExecutionContext(java.lang.String moduleName,
                                                java.lang.String moduleVersion)

Specified by:

findExecutionContext in class AbstractExecutionModulesManager

findExecutionFlowDescriptorConverter

protected ExecutionFlowDescriptorConverter findExecutionFlowDescriptorConverter(java.lang.String moduleName,
                                                                                java.lang.String moduleVersion)

moduleFilter

protected java.lang.String moduleFilter(java.lang.String moduleName,
                                        java.lang.String moduleVersion)

Only based on symbolic name if version is null or "0.0.0"

findRealizedFlow

public RealizedFlow findRealizedFlow(java.lang.String module,
                                     java.lang.String executionName)

Builds a minimal realized flow, based on the provided information (typically from the command line).

Parameters:

module - a bundle id, or a pattern contained in a bundle symbolic name

module - the execution flow name

Returns:

a minimal realized flow, to be used in an execution

upgrade

public void upgrade(NameVersion nameVersion)

Description copied from interface: ModulesManager

Synchronously upgrades the module referenced by this name version

Specified by:

upgrade in interface ModulesManager

getExecutionFlowDescriptorConverter

protected ExecutionFlowDescriptorConverter getExecutionFlowDescriptorConverter(java.lang.String moduleName,
                                                                               java.lang.String moduleVersion)

Specified by:

getExecutionFlowDescriptorConverter in class AbstractExecutionModulesManager

getExecutionFlowDescriptorConverter

protected ExecutionFlowDescriptorConverter getExecutionFlowDescriptorConverter(OsgiBundle osgiBundle)

getModuleDescriptor

public ModuleDescriptor getModuleDescriptor(java.lang.String moduleName,
                                            java.lang.String version)

Specified by:

getModuleDescriptor in interface ModulesManager

Returns:

a full fledged module descriptor.

listModules

public java.util.List<ModuleDescriptor> listModules()

Specified by:

listModules in interface ModulesManager

Returns:

a list of minimal module descriptors of the deployed modules

start

public void start(NameVersion nameVersion)

Description copied from interface: ModulesManager

Starts the module

Specified by:

start in interface ModulesManager

stop

public void stop(NameVersion nameVersion)

Description copied from interface: ModulesManager

Stops the module

Specified by:

stop in interface ModulesManager

setMetadataFromBundle

protected void setMetadataFromBundle(ModuleDescriptor md,
                                     Bundle bundle)

register

public void register(ExecutionContext executionContext,
                     java.util.Map<java.lang.String,java.lang.String> properties)

Registers an execution context.

unregister

public void unregister(ExecutionContext executionContext,
                       java.util.Map<java.lang.String,java.lang.String> properties)

Unregisters an execution context.

register

public void register(ExecutionFlow executionFlow,
                     java.util.Map<java.lang.String,java.lang.String> properties)

Registers an execution flow.

unregister

public void unregister(ExecutionFlow executionFlow,
                       java.util.Map<java.lang.String,java.lang.String> properties)

Unregisters an execution flow.

register

public void register(ExecutionModulesListener executionModulesListener,
                     java.util.Map<java.lang.String,java.lang.String> properties)

Registers an execution module listener.

unregister

public void unregister(ExecutionModulesListener executionModulesListener,
                       java.util.Map<java.lang.String,java.lang.String> properties)

Unregisters an execution module listener.

bundleChanged

public void bundleChanged(BundleEvent evt)

Specified by:

bundleChanged in interface BundleListener

bind

public void bind(java.lang.Object service,
                 java.util.Map properties)
          throws java.lang.Exception

Specified by:

bind in interface org.eclipse.gemini.blueprint.service.importer.OsgiServiceLifecycleListener

Throws:

java.lang.Exception

unbind

public void unbind(java.lang.Object service,
                   java.util.Map properties)
            throws java.lang.Exception

Specified by:

unbind in interface org.eclipse.gemini.blueprint.service.importer.OsgiServiceLifecycleListener

Throws:

java.lang.Exception

getMBeanServer

protected javax.management.MBeanServer getMBeanServer()

registerMBean

public void registerMBean(Module module,
                          ExecutionFlow executionFlow)

unregisterMBean

public void unregisterMBean(Module module,
                            ExecutionFlow executionFlow)

flowMBeanName

protected javax.management.ObjectName flowMBeanName(Module module,
                                                    ExecutionFlow executionFlow)

setBundlesManager

public void setBundlesManager(BundlesManager bundlesManager)

setDefaultDescriptorConverter

public void setDefaultDescriptorConverter(ExecutionFlowDescriptorConverter defaultDescriptorConverter)

setRegisterFlowsToJmx

public void setRegisterFlowsToJmx(java.lang.Boolean registerFlowsToJmx)