@ControlBoundary public interface Processor extends TokenProcessingEntity, Annotated<Processor>, Observable<ProcessorFinishedEvent>, WorkflowItem
Modifier and Type | Method and Description |
---|---|
void |
fire(String owningProcess,
InvocationContext context)
A processor with no inputs cannot be driven by the supply of data tokens
as it has nowhere to receive such tokens.
|
List<? extends Activity<?>> |
getActivityList()
A processor contains zero or more activities in an ordered list.
|
List<? extends Condition> |
getControlledPreconditionList()
A processor may control zero or more other processors within the same
level of the workflow through preconditions.
|
DispatchStack |
getDispatchStack()
The dispatch stack pulls jobs from the queue generated by the iteration
system and handles the dispatch of these jobs to appropriate activity
workers
|
List<? extends ProcessorInputPort> |
getInputPorts()
Each processor has a list of zero or more input ports.
|
IterationStrategyStack |
getIterationStrategy()
The iteration strategy is responsible for combining input data events
into jobs which are then queued for execution through the dispatch stack
|
List<? extends ProcessorOutputPort> |
getOutputPorts()
Each processor has a list of zero or more output ports.
|
List<? extends Condition> |
getPreconditionList()
A processor has zero or more preconditions explicitly declared.
|
doTypeCheck
getLocalName
getAddAnnotationEdit, getAnnotations, getRemoveAnnotationEdit, setAnnotations
addObserver, getObservers, removeObserver
@HierarchyTraversal(hierarchies="workflowStructure", role=CHILD) IterationStrategyStack getIterationStrategy()
@HierarchyTraversal(hierarchies="workflowStructure", role=CHILD) List<? extends ProcessorInputPort> getInputPorts()
Processor inputs are instances of FilteringInputPort - they must have the filter depth set before any data events arrive at the Processor. In addition they assume that a full collection will be supplied, i.e. that there will be exactly one event at the end of the list of events for a given process ID with an index array of length zero.
getInputPorts
in interface TokenProcessingEntity
@HierarchyTraversal(hierarchies="workflowStructure", role=CHILD) List<? extends ProcessorOutputPort> getOutputPorts()
getOutputPorts
in interface TokenProcessingEntity
@HierarchyTraversal(hierarchies="workflowStructure", role=CHILD) DispatchStack getDispatchStack()
@HierarchyTraversal(hierarchies="workflowStructure", role=CHILD) List<? extends Activity<?>> getActivityList()
void fire(String owningProcess, InvocationContext context)
@HierarchyTraversal(hierarchies="workflowStructure", role=CHILD) List<? extends Condition> getPreconditionList()
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.