org.sensorhub.impl.processing

Class ProcessingManagerImpl

java.lang.Object

org.sensorhub.impl.processing.ProcessingManagerImpl

All Implemented Interfaces:

IModuleManager<IProcessModule<?>>, IProcessingManager

public class ProcessingManagerImpl
extends Object
implements IProcessingManager

Default implementation of the processing manager interface

Since:

Feb 28, 2015

Author:

Alex Robin

Field Summary

Fields

Modifier and Type	Field and Description
protected ModuleRegistry	moduleRegistry

Constructor Summary

Constructors

Constructor and Description
ProcessingManagerImpl(ModuleRegistry moduleRegistry)

Method Summary

Methods

Modifier and Type	Method and Description
Future<?>	asyncExec(String processID, int priority) Executes the specified process in a separate thread with specified priority (If too many processes are already running, process may actually be scheduled for later execution)
List<String>	getAllProcessCodePackages()
List<ModuleConfig>	getAvailableModules() Gets the list of all modules handled by this manager that are configured but not yet loaded (i.e.
List<IProcessModule<?>>	getLoadedModules() Gets the list of all modules handled by this manager that are already loaded (i.e.
IProcessModule<?>	getModuleById(String moduleID) Retrieves a module instance by its local ID
void	installProcessCode(String processURI, DocFlavor.URL codePackage, boolean replace) Installs a process code package (jar file) from the specified URL for the process URI
boolean	isModuleLoaded(String moduleID)
void	syncExec(String processID) Executes the specified process synchronously (method will block until processing is complete)
void	uninstallProcessCode(String processURI) Uninstalls process code with specified URI

Methods inherited from class java.lang.Object

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

Field Detail

moduleRegistry

protected ModuleRegistry moduleRegistry

Constructor Detail

ProcessingManagerImpl

public ProcessingManagerImpl(ModuleRegistry moduleRegistry)

Method Detail

getLoadedModules

public List<IProcessModule<?>> getLoadedModules()

Description copied from interface: IModuleManager

Gets the list of all modules handled by this manager that are already loaded (i.e. enabled)

Specified by:

getLoadedModules in interface IModuleManager<IProcessModule<?>>

Returns:

list of module instances

isModuleLoaded

public boolean isModuleLoaded(String moduleID)

Specified by:

isModuleLoaded in interface IModuleManager<IProcessModule<?>>

Parameters:

moduleID - local ID of module

Returns:

true if module is loaded, false otherwise

getAvailableModules

public List<ModuleConfig> getAvailableModules()

Description copied from interface: IModuleManager

Gets the list of all modules handled by this manager that are configured but not yet loaded (i.e. disabled)

Specified by:

getAvailableModules in interface IModuleManager<IProcessModule<?>>

Returns:

list of module configuration classes

getModuleById

public IProcessModule<?> getModuleById(String moduleID)
                                throws SensorHubException

Description copied from interface: IModuleManager

Retrieves a module instance by its local ID

Specified by:

getModuleById in interface IModuleManager<IProcessModule<?>>

Parameters:

moduleID - Id of module to retrieve

Returns:

direct reference to the module instance

Throws:

SensorHubException

getAllProcessCodePackages

public List<String> getAllProcessCodePackages()

Specified by:

getAllProcessCodePackages in interface IProcessingManager

Returns:

the list of all process code configured on the system

installProcessCode

public void installProcessCode(String processURI,
                      DocFlavor.URL codePackage,
                      boolean replace)

Description copied from interface: IProcessingManager

Installs a process code package (jar file) from the specified URL for the process URI

Specified by:

installProcessCode in interface IProcessingManager

Parameters:

processURI - URI of process type that this code should be used for

codePackage - URL of jar containing classes necessary to run the specified method

replace - if true, old code associated to the same URI will be destroyed

uninstallProcessCode

public void uninstallProcessCode(String processURI)

Description copied from interface: IProcessingManager

Uninstalls process code with specified URI

Specified by:

uninstallProcessCode in interface IProcessingManager

syncExec

public void syncExec(String processID)

Description copied from interface: IProcessingManager

Executes the specified process synchronously (method will block until processing is complete)

Specified by:

syncExec in interface IProcessingManager

asyncExec

public Future<?> asyncExec(String processID,
                  int priority)

Description copied from interface: IProcessingManager

Executes the specified process in a separate thread with specified priority (If too many processes are already running, process may actually be scheduled for later execution)

Specified by:

asyncExec in interface IProcessingManager

Returns:

Future object allowing the caller can cancel and know when process is actually terminated