Object -
streams
:
AbstractPatternProcessor
Abstract processor encapsulating pattern processor functions.
Methods
Processes the StreamEvent
.
Sets a link to the previous AbstractOperatorProcessor
.
Returns the alias of the current processor.
Set the StateMachine
to the procesor and it's descendants.
Validates the processor and its configs.
Removes a given StreamEvent
from the StateMachine
.
Fields
- prevProcessor AbstractOperatorProcessor?
-
link to the previous processor
- stateMachine StateMachine?
-
link to the state machine
- lockField int
-
lock object to be used with lock blocks
Processes the StreamEvent
.
Parameters
- event StreamEvent
-
event to process
- processorAlias string?
-
alias for the calling processor, for identification purposes (lhs, rhs).
-
Return Type
([boolean, boolean]) a tuple indicating, whether the event is promoted and whether to continue to the next processor.
Sets a link to the previous AbstractOperatorProcessor
.
Parameters
- processor AbstractOperatorProcessor
-
previous processor
Returns the alias of the current processor.
-
Return Type
(string) alias of the processor.
Set the StateMachine
to the procesor and it's descendants.
Parameters
- stateMachine StateMachine
-
StateMachine
instance
Removes a given StreamEvent
from the StateMachine
.
Parameters
- streamEvent StreamEvent
-
event to be removed