public class EngineWorkflowExecutor extends BaseWorkflowExecutor
Modifier and Type | Class and Description |
---|---|
static class |
EngineWorkflowExecutor.BaseProfile
Base profile which provides initial states
|
BaseWorkflowExecutor.BaseWorkflowExecutionResult, BaseWorkflowExecutor.StepResultCapture
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
STEP_AFTER_KEY |
static java.lang.String |
STEP_ANY_FLOW_CONTROL_HALT_KEY |
static java.lang.String |
STEP_ANY_STATE_FAILED_KEY |
static java.lang.String |
STEP_ANY_STATE_SKIPPED_KEY |
static java.lang.String |
STEP_ANY_STATE_SUCCESS_KEY |
static java.lang.String |
STEP_BEFORE_KEY |
static java.lang.String |
STEP_COMPLETED_KEY |
static java.lang.String |
STEP_CONTROL_KEY |
static java.lang.String |
STEP_CONTROL_SKIP_KEY |
static java.lang.String |
STEP_CONTROL_START |
static java.lang.String |
STEP_DATA_RESULT_KEY_PREFIX |
static java.lang.String |
STEP_FLOW_CONTROL_KEY |
static java.lang.String |
STEP_FLOW_CONTROL_STATUS_KEY |
static java.lang.String |
STEP_STATE_KEY |
static java.lang.String |
STEP_STATE_RESULT_FAILURE |
static java.lang.String |
STEP_STATE_RESULT_SKIPPED |
static java.lang.String |
STEP_STATE_RESULT_SUCCESS |
static java.lang.String |
VALUE_FALSE |
static java.lang.String |
VALUE_TRUE |
static java.lang.String |
WORKFLOW_KEEPGOING_KEY |
static java.lang.String |
WORKFLOW_STATE_KEY |
static java.lang.String |
WORKFLOW_STATE_STARTED |
OPTION_KEY, SECURE_OPTION_KEY, SECURE_OPTION_VALUE, WorkflowResultFailed
NODE_FIRST, PARALLEL, STEP_FIRST
Constructor and Description |
---|
EngineWorkflowExecutor(Framework framework) |
Modifier and Type | Method and Description |
---|---|
WorkflowSystem |
buildWorkflowSystem(StepExecutionContext executionContext,
MutableStateObj state,
RuleEngine ruleEngine,
int wfThreadcount) |
WorkflowExecutionResult |
executeWorkflowImpl(StepExecutionContext executionContext,
WorkflowExecutionItem item) |
WorkflowSystemBuilder |
getWorkflowSystemBuilder() |
WorkflowStrategy |
setupWorkflowStrategy(StepExecutionContext executionContext,
WorkflowExecutionItem item,
IWorkflow workflow,
java.lang.String strategy) |
void |
setWorkflowSystemBuilder(WorkflowSystemBuilder workflowSystemBuilder) |
static java.lang.String |
stepKey(java.lang.String key,
java.lang.Object stepNum) |
static void |
updateStateWithStepResultData(MutableStateObj state,
java.lang.Object identity,
java.util.Map<java.lang.String,java.lang.Object> failureData) |
addNodeStepFailureContextData, addStepFailureContextData, combineNodeResultData, combineResultData, convertFailures, createPrintableDataContext, createPrintableDataContext, executeWFItem, executeWorkflow, executeWorkflowItemsForNodeSet, executeWorkflowStep, getFramework, getWorkflowListener, nodeStepResultFromNodeStepException, replaceFailedNodesListenerInContext, reportNodesMatched, workflowResult
public static final java.lang.String STEP_FLOW_CONTROL_KEY
public static final java.lang.String STEP_ANY_FLOW_CONTROL_HALT_KEY
public static final java.lang.String STEP_FLOW_CONTROL_STATUS_KEY
public static final java.lang.String WORKFLOW_STATE_KEY
public static final java.lang.String WORKFLOW_KEEPGOING_KEY
public static final java.lang.String WORKFLOW_STATE_STARTED
public static final java.lang.String STEP_BEFORE_KEY
public static final java.lang.String STEP_AFTER_KEY
public static final java.lang.String STEP_STATE_KEY
public static final java.lang.String STEP_ANY_STATE_SKIPPED_KEY
public static final java.lang.String STEP_ANY_STATE_SUCCESS_KEY
public static final java.lang.String STEP_ANY_STATE_FAILED_KEY
public static final java.lang.String STEP_COMPLETED_KEY
public static final java.lang.String VALUE_TRUE
public static final java.lang.String VALUE_FALSE
public static final java.lang.String STEP_STATE_RESULT_SUCCESS
public static final java.lang.String STEP_STATE_RESULT_FAILURE
public static final java.lang.String STEP_STATE_RESULT_SKIPPED
public static final java.lang.String STEP_CONTROL_KEY
public static final java.lang.String STEP_CONTROL_SKIP_KEY
public static final java.lang.String STEP_CONTROL_START
public static final java.lang.String STEP_DATA_RESULT_KEY_PREFIX
public EngineWorkflowExecutor(Framework framework)
public static java.lang.String stepKey(java.lang.String key, java.lang.Object stepNum)
public static void updateStateWithStepResultData(MutableStateObj state, java.lang.Object identity, java.util.Map<java.lang.String,java.lang.Object> failureData)
public WorkflowSystemBuilder getWorkflowSystemBuilder()
public void setWorkflowSystemBuilder(WorkflowSystemBuilder workflowSystemBuilder)
public WorkflowExecutionResult executeWorkflowImpl(StepExecutionContext executionContext, WorkflowExecutionItem item)
executeWorkflowImpl
in class BaseWorkflowExecutor
public WorkflowSystem buildWorkflowSystem(StepExecutionContext executionContext, MutableStateObj state, RuleEngine ruleEngine, int wfThreadcount)
public WorkflowStrategy setupWorkflowStrategy(StepExecutionContext executionContext, WorkflowExecutionItem item, IWorkflow workflow, java.lang.String strategy) throws ExecutionServiceException
ExecutionServiceException