|
__init__(self)
Sets up the queues for incoming messages. |
source code
|
|
|
startup(self)
Start up the data engine in its background thread. |
source code
|
|
|
runUntilShutdown(self)
In here, all the queues are checked frequently and appropriate
actions are undertaken. |
source code
|
|
|
shutdown(self)
Shutdown the data engine thread. |
source code
|
|
|
_executeOneReaction(self,
event,
reaction)
Performs all operations as defined by the reaction part of an
ioids rule. |
source code
|
|
|
_processEventFromLocal(self,
event)
Processes one item from the local event list. |
source code
|
|
|
|
|
|
|
|
|
newIoidsEventFromRemote(self,
ioidsevent,
relations=[ ] ) |
source code
|
|