public class OsgiExecutionModulesManager extends AbstractExecutionModulesManager implements org.eclipse.gemini.blueprint.service.importer.OsgiServiceLifecycleListener, BundleListener
SLC_PROCESS_ID, UNIQUE_LAUNCH_FLOW_PROPERTY, UNIQUE_LAUNCH_MODULE_PROPERTY
Constructor and Description |
---|
OsgiExecutionModulesManager() |
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
|
execute
public void init() throws java.lang.Exception
java.lang.Exception
public void destroy()
protected void executeFlowAndExit(java.lang.String module, java.lang.String version, java.lang.String flow)
public ExecutionModuleDescriptor getExecutionModuleDescriptor(java.lang.String moduleName, java.lang.String version)
getExecutionModuleDescriptor
in interface ExecutionModulesManager
public java.util.List<ExecutionModuleDescriptor> listExecutionModules()
listExecutionModules
in interface ExecutionModulesManager
protected java.util.Map<java.lang.String,ExecutionFlow> listFlows(java.lang.String moduleName, java.lang.String moduleVersion)
protected ExecutionFlow findExecutionFlow(java.lang.String moduleName, java.lang.String moduleVersion, java.lang.String flowName)
findExecutionFlow
in class AbstractExecutionModulesManager
protected ExecutionContext findExecutionContext(java.lang.String moduleName, java.lang.String moduleVersion)
findExecutionContext
in class AbstractExecutionModulesManager
protected ExecutionFlowDescriptorConverter findExecutionFlowDescriptorConverter(java.lang.String moduleName, java.lang.String moduleVersion)
protected java.lang.String moduleFilter(java.lang.String moduleName, java.lang.String moduleVersion)
public RealizedFlow findRealizedFlow(java.lang.String module, java.lang.String executionName)
module
- a bundle id, or a pattern contained in a bundle symbolic namemodule
- the execution flow namepublic void upgrade(NameVersion nameVersion)
ModulesManager
upgrade
in interface ModulesManager
protected ExecutionFlowDescriptorConverter getExecutionFlowDescriptorConverter(java.lang.String moduleName, java.lang.String moduleVersion)
getExecutionFlowDescriptorConverter
in class AbstractExecutionModulesManager
protected ExecutionFlowDescriptorConverter getExecutionFlowDescriptorConverter(OsgiBundle osgiBundle)
public ModuleDescriptor getModuleDescriptor(java.lang.String moduleName, java.lang.String version)
getModuleDescriptor
in interface ModulesManager
public java.util.List<ModuleDescriptor> listModules()
listModules
in interface ModulesManager
public void start(NameVersion nameVersion)
ModulesManager
start
in interface ModulesManager
public void stop(NameVersion nameVersion)
ModulesManager
stop
in interface ModulesManager
protected void setMetadataFromBundle(ModuleDescriptor md, Bundle bundle)
public void register(ExecutionContext executionContext, java.util.Map<java.lang.String,java.lang.String> properties)
public void unregister(ExecutionContext executionContext, java.util.Map<java.lang.String,java.lang.String> properties)
public void register(ExecutionFlow executionFlow, java.util.Map<java.lang.String,java.lang.String> properties)
public void unregister(ExecutionFlow executionFlow, java.util.Map<java.lang.String,java.lang.String> properties)
public void register(ExecutionModulesListener executionModulesListener, java.util.Map<java.lang.String,java.lang.String> properties)
public void unregister(ExecutionModulesListener executionModulesListener, java.util.Map<java.lang.String,java.lang.String> properties)
public void bundleChanged(BundleEvent evt)
bundleChanged
in interface BundleListener
public void bind(java.lang.Object service, java.util.Map properties) throws java.lang.Exception
bind
in interface org.eclipse.gemini.blueprint.service.importer.OsgiServiceLifecycleListener
java.lang.Exception
public void unbind(java.lang.Object service, java.util.Map properties) throws java.lang.Exception
unbind
in interface org.eclipse.gemini.blueprint.service.importer.OsgiServiceLifecycleListener
java.lang.Exception
protected javax.management.MBeanServer getMBeanServer()
public void registerMBean(Module module, ExecutionFlow executionFlow)
public void unregisterMBean(Module module, ExecutionFlow executionFlow)
protected javax.management.ObjectName flowMBeanName(Module module, ExecutionFlow executionFlow)
public void setBundlesManager(BundlesManager bundlesManager)
public void setDefaultDescriptorConverter(ExecutionFlowDescriptorConverter defaultDescriptorConverter)
public void setRegisterFlowsToJmx(java.lang.Boolean registerFlowsToJmx)
Copyright © 2007–2020. All rights reserved.