Modifier and Type | Method and Description |
---|---|
void |
IEventProducer.registerListener(IEventListener listener)
Registers a listener with this event producer.
|
boolean |
IEventMultiTopicProducer.registerListener(String topic,
IEventListener listener)
Registers a listener with the given topic.
|
void |
IEventProducer.unregisterListener(IEventListener listener)
Unregisters a listener from this event producer.
|
void |
IEventMultiTopicProducer.unregisterListener(String topic,
IEventListener listener)
Unregisters a listener from this event producer.
|
Modifier and Type | Method and Description |
---|---|
void |
IModule.registerListener(IEventListener listener)
Registers a listener to receive events generated by this module.
When this method is called, the current state of the module is also notified synchronously to guarantee that the listener always receives it. |
void |
IModule.unregisterListener(IEventListener listener)
Unregisters a listener and thus stop receiving events generayed by this module
|
Modifier and Type | Interface and Description |
---|---|
interface |
IStreamProcessModule<ConfigType extends StreamProcessConfig>
Interface for all event stream processors.
This type of process is started in a persistent manner and listens to incoming events. |
Modifier and Type | Class and Description |
---|---|
class |
SOSTClient
Implementation of an SOS-T client that listens to sensor events and
forwards them to an SOS via InsertSensor/UpdateSensor, InsertResultTemplate
and InsertResult requests.
|
Modifier and Type | Method and Description |
---|---|
void |
BasicEventHandler.registerListener(IEventListener listener) |
void |
AsyncEventHandler.registerListener(IEventListener listener) |
void |
EventBus.registerListener(String moduleID,
String topic,
IEventListener listener) |
void |
BasicEventHandler.unregisterListener(IEventListener listener) |
void |
AsyncEventHandler.unregisterListener(IEventListener listener) |
void |
EventBus.unregisterListener(String moduleID,
String topic,
IEventListener listener) |
Modifier and Type | Class and Description |
---|---|
class |
ModuleRegistry
This class is in charge of loading all configured modules on startup
as well as dynamically loading/unloading modules on demand.
|
Modifier and Type | Method and Description |
---|---|
IModule<?> |
ModuleRegistry.initModuleAsync(String moduleID,
boolean force,
IEventListener listener)
Initializes the module with the given local ID
This method is asynchronous so it returns immediately and the listener will be notified when the module is actually initialized |
IModule<?> |
ModuleRegistry.loadModuleAsync(ModuleConfig config,
IEventListener listener)
Instantiates and loads a module using the given configuration
This method is asynchronous so, when it returns without error, the module is guaranteed to be loaded but not necessarilly initialized or started. |
void |
AbstractModule.registerListener(IEventListener listener) |
void |
ModuleRegistry.registerListener(IEventListener listener) |
void |
ModuleRegistry.restartModuleAsync(String moduleID,
IEventListener listener)
Restarts the module with the given local ID
This method is asynchronous so it returns immediately and the listener will be notified when the module is actually restarted |
IModule<?> |
ModuleRegistry.startModuleAsync(String moduleID,
IEventListener listener)
Starts the module with the given local ID
This method is asynchronous so it returns immediately and the listener will be notified when the module is actually started |
IModule<?> |
ModuleRegistry.stopModuleAsync(String moduleID,
IEventListener listener)
Stops the module with the given local ID
This method is asynchronous so it returns immediately and the listener will be notified when the module is actually stopped |
void |
AbstractModule.unregisterListener(IEventListener listener) |
void |
ModuleRegistry.unregisterListener(IEventListener listener) |
Modifier and Type | Class and Description |
---|---|
class |
GenericStreamStorage
Generic wrapper/adapter enabling any storage implementation to store data
coming from data events (e.g.
|
Modifier and Type | Method and Description |
---|---|
void |
InMemoryBasicStorage.registerListener(IEventListener listener) |
void |
InMemoryBasicStorage.unregisterListener(IEventListener listener) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractStreamProcess<ConfigType extends StreamProcessConfig>
Class providing default implementation of common stream processing API methods.
|
class |
SMLStreamProcess
Implementation of process module fully configured using a SensorML process
chain description.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractSensorControl.registerListener(IEventListener listener) |
void |
AbstractSensorOutput.registerListener(IEventListener listener) |
void |
AbstractSensorControl.unregisterListener(IEventListener listener) |
void |
AbstractSensorOutput.unregisterListener(IEventListener listener) |
Modifier and Type | Class and Description |
---|---|
class |
SensorDataProvider
Implementation of SOS data provider connecting to a sensor via
SensorHub's sensor API (ISensorDataInterface).
Most of the logic is inherited from StreamDataProvider . |
class |
SensorDataProviderFactory
Factory for sensor data providers.
Most of the logic is inherited from StreamDataProviderFactory . |
class |
SensorWithStorageProviderFactory
Factory for sensor data providers with storage.
Most of the logic is inherited from StreamWithStorageProviderFactory . |
class |
SOSService
Implementation of SensorHub generic SOS service.
|
class |
StorageDataProviderFactory
Factory for storage data providers.
|
class |
StreamDataProvider
Implementation of SOS data provider connecting to a streaming data source
|
class |
StreamDataProviderFactory<ProducerType extends IDataProducerModule<?>>
Base factory for streaming data providers.
|
class |
StreamProcessDataProvider
Implementation of SOS data provider connecting to a process via
SensorHub's stream processing API.
Most of the logic is inherited from StreamDataProvider . |
class |
StreamProcessProviderFactory
Factory for stream processing data providers.
Most of the logic is inherited from StreamDataProviderFactory . |
class |
StreamProcessWithStorageProviderFactory
Factory for streaming data providers with storage.
Most of the logic is inherited from StreamWithStorageProviderFactory . |
class |
StreamWithStorageProviderFactory<ProducerType extends IDataProducerModule<?>>
Factory for streaming data providers with storage.
Most of the logic is inherited from StorageDataProviderFactory . |
Modifier and Type | Class and Description |
---|---|
class |
DirectSensorConnector
SPS connector for directly sending commands to sensors.
|
class |
SharedSensorConnector
SPS connector for handling commands sent to sensors.
|
class |
SPSService
Implementation of SensorHub generic SPS service.
|
Modifier and Type | Class and Description |
---|---|
class |
AdminUI |
class |
AdminUIModule |
class |
DefaultModulePanel<ModuleType extends IModule<? extends ModuleConfig>>
Default implementation of module panel letting the user edit the module
configuration through a generic auto-generated form.
|
class |
NetworkAdminPanel
Admin panel for networking modules.
This adds features to view available networks and scan for devices. |
class |
SensorAdminPanel
Admin panel for sensor modules.
This adds a section to view structure of inputs and outputs, and allows the user to send commands and view output data values. |
class |
StorageAdminPanel
Admin panel for sensor modules.
This adds a section to view structure of inputs and outputs, and allows the user to send commands and view output data values. |
Copyright © 2016 Sensia Software LLC. All rights reserved.