Modifier and Type | Method and Description |
---|---|
protected ActivityExecution |
ParallelMultiInstanceActivityBehavior.createConcurrentExecution(ActivityExecution scopeExecution) |
ActivityExecution |
SequentialMultiInstanceActivityBehavior.createInnerInstance(ActivityExecution scopeExecution) |
ActivityExecution |
ParallelMultiInstanceActivityBehavior.createInnerInstance(ActivityExecution scopeExecution) |
Modifier and Type | Method and Description |
---|---|
protected Collection<ActivityExecution> |
InclusiveGatewayActivityBehavior.getLeafExecutions(ActivityExecution parent) |
List<ActivityExecution> |
SequentialMultiInstanceActivityBehavior.initializeScope(ActivityExecution scopeExecution,
int nrOfInstances) |
List<ActivityExecution> |
ParallelMultiInstanceActivityBehavior.initializeScope(ActivityExecution scopeExecution,
int numberOfInstances) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
InclusiveGatewayActivityBehavior.activatesGateway(ActivityExecution execution,
PvmActivity gatewayActivity) |
protected boolean |
ParallelMultiInstanceActivityBehavior.allExecutionsEnded(ActivityExecution scopeExecution,
ActivityExecution endedExecution) |
protected boolean |
InclusiveGatewayActivityBehavior.canReachActivity(ActivityExecution execution,
PvmActivity activity) |
protected List<EventSubscriptionEntity> |
CompensationEventActivityBehavior.collectEventSubscriptions(ActivityExecution execution) |
void |
SequentialMultiInstanceActivityBehavior.complete(ActivityExecution scopeExecution) |
void |
EventSubProcessActivityBehavior.complete(ActivityExecution scopeExecution) |
void |
ParallelMultiInstanceActivityBehavior.complete(ActivityExecution scopeExecution) |
void |
SubProcessActivityBehavior.complete(ActivityExecution scopeExecution) |
void |
CallableElementActivityBehavior.completed(ActivityExecution execution) |
protected boolean |
MultiInstanceActivityBehavior.completionConditionSatisfied(ActivityExecution execution) |
void |
SequentialMultiInstanceActivityBehavior.concurrentChildExecutionEnded(ActivityExecution scopeExecution,
ActivityExecution endedExecution) |
void |
EventSubProcessActivityBehavior.concurrentChildExecutionEnded(ActivityExecution scopeExecution,
ActivityExecution endedExecution) |
void |
ParallelMultiInstanceActivityBehavior.concurrentChildExecutionEnded(ActivityExecution scopeExecution,
ActivityExecution endedExecution) |
void |
SubProcessActivityBehavior.concurrentChildExecutionEnded(ActivityExecution scopeExecution,
ActivityExecution endedExecution) |
protected void |
AbstractBpmnActivityBehavior.createCompensateEventSubscription(ActivityExecution execution,
ActivityImpl compensationHandler) |
protected ActivityExecution |
ParallelMultiInstanceActivityBehavior.createConcurrentExecution(ActivityExecution scopeExecution) |
ActivityExecution |
SequentialMultiInstanceActivityBehavior.createInnerInstance(ActivityExecution scopeExecution) |
ActivityExecution |
ParallelMultiInstanceActivityBehavior.createInnerInstance(ActivityExecution scopeExecution) |
protected void |
SequentialMultiInstanceActivityBehavior.createInstances(ActivityExecution execution,
int nrOfInstances) |
protected void |
ParallelMultiInstanceActivityBehavior.createInstances(ActivityExecution execution,
int nrOfInstances) |
protected abstract void |
MultiInstanceActivityBehavior.createInstances(ActivityExecution execution,
int nrOfInstances) |
void |
SequentialMultiInstanceActivityBehavior.destroyInnerInstance(ActivityExecution scopeExecution) |
void |
ParallelMultiInstanceActivityBehavior.destroyInnerInstance(ActivityExecution concurrentExecution) |
void |
CancelEndEventActivityBehavior.doLeave(ActivityExecution execution) |
void |
AbstractBpmnActivityBehavior.doLeave(ActivityExecution execution)
Subclasses that call leave() will first pass through this method, before
the regular
FlowNodeActivityBehavior.leave(ActivityExecution) is
called. |
void |
ExclusiveGatewayActivityBehavior.doLeave(ActivityExecution execution)
The default behaviour of BPMN, taking every outgoing sequence flow
(where the condition evaluates to true), is not valid for an exclusive
gateway.
|
void |
SubProcessActivityBehavior.doLeave(ActivityExecution execution) |
void |
FlowNodeActivityBehavior.doLeave(ActivityExecution execution) |
void |
MultiInstanceActivityBehavior.doLeave(ActivityExecution execution) |
void |
ServiceTaskDelegateExpressionActivityBehavior.doSignal(ActivityExecution execution,
String signalName,
Object signalData) |
protected void |
ClassDelegateActivityBehavior.doSignal(ActivityExecution execution,
String signalName,
Object signalData) |
protected void |
MultiInstanceActivityBehavior.evaluateCollectionVariable(ActivityExecution execution,
int loopCounter) |
void |
IntermediateCatchLinkEventActivityBehavior.execute(ActivityExecution execution) |
void |
ClassDelegateActivityBehavior.execute(ActivityExecution execution) |
void |
NoneEndEventActivityBehavior.execute(ActivityExecution execution) |
void |
ExternalTaskActivityBehavior.execute(ActivityExecution execution) |
void |
CancelEndEventActivityBehavior.execute(ActivityExecution execution) |
void |
IntermediateConditionalEventBehavior.execute(ActivityExecution execution) |
void |
ShellActivityBehavior.execute(ActivityExecution execution) |
void |
TerminateEndEventActivityBehavior.execute(ActivityExecution execution) |
void |
EventBasedGatewayActivityBehavior.execute(ActivityExecution execution) |
void |
IntermediateCatchEventActivityBehavior.execute(ActivityExecution execution) |
void |
ErrorEndEventActivityBehavior.execute(ActivityExecution execution) |
void |
MailActivityBehavior.execute(ActivityExecution execution) |
void |
CustomActivityBehavior.execute(ActivityExecution execution) |
void |
CallableElementActivityBehavior.execute(ActivityExecution execution) |
void |
InclusiveGatewayActivityBehavior.execute(ActivityExecution execution) |
void |
ThrowSignalEventActivityBehavior.execute(ActivityExecution execution) |
void |
ParallelGatewayActivityBehavior.execute(ActivityExecution execution) |
void |
SubProcessActivityBehavior.execute(ActivityExecution execution) |
void |
DmnBusinessRuleTaskActivityBehavior.execute(ActivityExecution execution) |
void |
FlowNodeActivityBehavior.execute(ActivityExecution execution)
Default behaviour: just leave the activity with no extra functionality.
|
void |
CompensationEventActivityBehavior.execute(ActivityExecution execution) |
void |
MultiInstanceActivityBehavior.execute(ActivityExecution execution) |
void |
ThrowEscalationEventActivityBehavior.execute(ActivityExecution execution) |
void |
TaskActivityBehavior.execute(ActivityExecution execution) |
protected void |
AbstractBpmnActivityBehavior.executeWithErrorPropagation(ActivityExecution execution,
Callable<Void> toExecute)
Takes an
ActivityExecution and an Callable and wraps
the call to the Callable with the proper error propagation. |
protected ActivityBehavior |
ClassDelegateActivityBehavior.getActivityBehaviorInstance(ActivityExecution execution) |
protected ActivityBehavior |
ServiceTaskDelegateExpressionActivityBehavior.getActivityBehaviorInstance(ActivityExecution execution,
Object delegateInstance) |
protected String |
CallableElementActivityBehavior.getBusinessKey(ActivityExecution execution) |
protected String |
CallableElementActivityBehavior.getDeploymentId(ActivityExecution execution) |
protected org.camunda.bpm.engine.variable.VariableMap |
CallableElementActivityBehavior.getInputVariables(ActivityExecution callingExecution) |
protected Collection<ActivityExecution> |
InclusiveGatewayActivityBehavior.getLeafExecutions(ActivityExecution parent) |
protected Integer |
MultiInstanceActivityBehavior.getLocalLoopVariable(ActivityExecution execution,
String variableName) |
protected Integer |
MultiInstanceActivityBehavior.getLoopVariable(ActivityExecution execution,
String variableName) |
protected Integer |
CallableElementActivityBehavior.getVersion(ActivityExecution execution) |
boolean |
MultiInstanceActivityBehavior.hasLoopVariable(ActivityExecution execution,
String variableName) |
List<ActivityExecution> |
SequentialMultiInstanceActivityBehavior.initializeScope(ActivityExecution scopeExecution,
int nrOfInstances) |
List<ActivityExecution> |
ParallelMultiInstanceActivityBehavior.initializeScope(ActivityExecution scopeExecution,
int numberOfInstances) |
protected Object |
CallableElementActivityBehavior.instantiateDelegateClass(ActivityExecution execution) |
protected boolean |
BpmnActivityBehavior.isAncestorCompensationThrowing(ActivityExecution execution) |
void |
FlowNodeActivityBehavior.leave(ActivityExecution execution)
Default way of leaving a BPMN 2.0 activity: evaluate the conditions on the
outgoing sequence flow and take those that evaluate to true.
|
protected void |
ThrowEscalationEventActivityBehavior.leaveExecution(ActivityExecution execution,
PvmActivity currentActivity,
EscalationEventDefinition escalationEventDefinition) |
protected void |
FlowNodeActivityBehavior.leaveIgnoreConditions(ActivityExecution activityContext) |
protected void |
GatewayActivityBehavior.lockConcurrentRoot(ActivityExecution execution) |
void |
CaseCallActivityBehavior.migrateScope(ActivityExecution scopeExecution) |
void |
UserTaskActivityBehavior.migrateScope(ActivityExecution scopeExecution) |
void |
ExternalTaskActivityBehavior.migrateScope(ActivityExecution scopeExecution) |
void |
ParallelMultiInstanceActivityBehavior.migrateScope(ActivityExecution scopeExecution) |
void |
CallActivityBehavior.migrateScope(ActivityExecution scopeExecution) |
void |
CallableElementActivityBehavior.passOutputVariables(ActivityExecution execution,
VariableScope subInstance) |
void |
BpmnActivityBehavior.performDefaultOutgoingBehavior(ActivityExecution activityExceution)
Performs the default outgoing BPMN 2.0 behavior, which is having parallel
paths of executions for the outgoing sequence flow.
|
void |
ServiceTaskDelegateExpressionActivityBehavior.performExecution(ActivityExecution execution) |
void |
UserTaskActivityBehavior.performExecution(ActivityExecution execution) |
void |
ReceiveTaskActivityBehavior.performExecution(ActivityExecution execution) |
void |
ServiceTaskJavaDelegateActivityBehavior.performExecution(ActivityExecution execution) |
void |
ServiceTaskExpressionActivityBehavior.performExecution(ActivityExecution execution) |
void |
ScriptTaskActivityBehavior.performExecution(ActivityExecution execution) |
protected void |
TaskActivityBehavior.performExecution(ActivityExecution execution)
The method which should be overridden by the sub classes to perform an execution.
|
void |
BpmnActivityBehavior.performIgnoreConditionsOutgoingBehavior(ActivityExecution activityExecution)
Performs the default outgoing BPMN 2.0 behavior (@see
BpmnActivityBehavior.performDefaultOutgoingBehavior(ActivityExecution) ), but without
checking the conditions on the outgoing sequence flow. |
protected void |
MultiInstanceActivityBehavior.performInstance(ActivityExecution execution,
PvmActivity activity,
int loopCounter) |
protected void |
BpmnActivityBehavior.performOutgoingBehavior(ActivityExecution execution,
boolean checkConditions,
boolean throwExceptionIfExecutionStuck,
List<ActivityExecution> reusableExecutions)
Actual implementation of leaving an activity.
|
protected void |
TaskActivityBehavior.postExecution(ActivityExecution execution)
The method which will be called after performing the execution.
|
protected void |
TaskActivityBehavior.preExecution(ActivityExecution execution)
The method which will be called before the execution is performed.
|
protected void |
SequentialMultiInstanceActivityBehavior.prepareScope(ActivityExecution scopeExecution,
int totalNumberOfInstances) |
protected void |
ParallelMultiInstanceActivityBehavior.prepareScopeExecution(ActivityExecution scopeExecution,
int nrOfInstances) |
void |
ExternalTaskActivityBehavior.propagateBpmnError(BpmnError error,
ActivityExecution execution)
Overrides the propagateBpmnError method to made it public.
|
protected void |
AbstractBpmnActivityBehavior.propagateBpmnError(BpmnError error,
ActivityExecution execution) |
protected void |
AbstractBpmnActivityBehavior.propagateError(String errorCode,
String errorMessage,
Exception origException,
ActivityExecution execution) |
protected void |
AbstractBpmnActivityBehavior.propagateException(ActivityExecution execution,
Exception ex)
Decides how to propagate the exception properly, e.g.
|
protected void |
AbstractBpmnActivityBehavior.propagateExceptionAsError(Exception exception,
ActivityExecution execution) |
void |
MultiInstanceActivityBehavior.removeLoopVariable(ActivityExecution execution,
String variableName) |
Object |
CallableElementActivityBehavior.resolveDelegateClass(ActivityExecution execution) |
protected DelegateVariableMapping |
CallableElementActivityBehavior.resolveDelegation(ActivityExecution execution) |
protected int |
MultiInstanceActivityBehavior.resolveLoopCardinality(ActivityExecution execution) |
protected int |
MultiInstanceActivityBehavior.resolveNrOfInstances(ActivityExecution execution) |
protected void |
MultiInstanceActivityBehavior.setLoopVariable(ActivityExecution execution,
String variableName,
Object value) |
void |
ServiceTaskDelegateExpressionActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
ClassDelegateActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
UserTaskActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
ExternalTaskActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
CancelEndEventActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
AbstractBpmnActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
ReceiveTaskActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object data) |
void |
CancelBoundaryEventActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
IntermediateCatchEventActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
CustomActivityBehavior.signal(ActivityExecution execution,
String signalEvent,
Object signalData) |
void |
FlowNodeActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
void |
CompensationEventActivityBehavior.signal(ActivityExecution execution,
String signalName,
Object signalData) |
protected void |
AbstractBpmnActivityBehavior.signalCompensationDone(ActivityExecution execution) |
protected void |
CaseCallActivityBehavior.startInstance(ActivityExecution execution,
org.camunda.bpm.engine.variable.VariableMap variables,
String businessKey) |
protected abstract void |
CallableElementActivityBehavior.startInstance(ActivityExecution execution,
org.camunda.bpm.engine.variable.VariableMap variables,
String businessKey) |
protected void |
CallActivityBehavior.startInstance(ActivityExecution execution,
org.camunda.bpm.engine.variable.VariableMap variables,
String businessKey) |
Modifier and Type | Method and Description |
---|---|
protected void |
BpmnActivityBehavior.performOutgoingBehavior(ActivityExecution execution,
boolean checkConditions,
boolean throwExceptionIfExecutionStuck,
List<ActivityExecution> reusableExecutions)
Actual implementation of leaving an activity.
|
Modifier and Type | Field and Description |
---|---|
protected ActivityExecution |
ActivityBehaviorSignalInvocation.execution |
protected ActivityExecution |
ActivityBehaviorInvocation.execution |
Constructor and Description |
---|
ActivityBehaviorInvocation(ActivityBehavior behaviorInstance,
ActivityExecution execution) |
ActivityBehaviorSignalInvocation(SignallableActivityBehavior behaviorInstance,
ActivityExecution execution,
String signalName,
Object signalData) |
Modifier and Type | Method and Description |
---|---|
static List<EventSubscriptionEntity> |
CompensationUtil.collectCompensateEventSubscriptionsForActivity(ActivityExecution execution,
String activityRef)
Collect all compensate event subscriptions for activity on the scope of
given execution.
|
static List<EventSubscriptionEntity> |
CompensationUtil.collectCompensateEventSubscriptionsForScope(ActivityExecution execution)
Collect all compensate event subscriptions for scope of given execution.
|
static void |
CompensationUtil.throwCompensationEvent(List<EventSubscriptionEntity> eventSubscriptions,
ActivityExecution execution,
boolean async)
we create a separate execution for each compensation handler invocation.
|
Modifier and Type | Class and Description |
---|---|
class |
ExecutionEntity |
Modifier and Type | Method and Description |
---|---|
ActivityExecution |
ActivityExecution.createExecution()
creates a new execution.
|
ActivityExecution |
ActivityExecution.createExecution(boolean initializeExecutionStartContext)
creates a new execution.
|
ActivityExecution |
ModificationObserverBehavior.createInnerInstance(ActivityExecution scopeExecution)
Returns an execution that can be used to execute an activity within that scope.
|
ActivityExecution |
ActivityExecution.findExecutionForFlowScope(PvmScope targetScope)
Assumption: the current execution is active and executing an activity (
getActivity() is not null). |
ActivityExecution |
ActivityExecution.getParent()
returns the parent of this execution, or null if there no parent.
|
Modifier and Type | Method and Description |
---|---|
List<ActivityExecution> |
ActivityExecution.findInactiveChildExecutions(PvmActivity activity) |
List<ActivityExecution> |
ActivityExecution.findInactiveConcurrentExecutions(PvmActivity activity)
Retrieves all executions which are concurrent and inactive at the given activity.
|
List<? extends ActivityExecution> |
ActivityExecution.getExecutions()
returns the list of execution of which this execution the parent of.
|
List<? extends ActivityExecution> |
ActivityExecution.getNonEventScopeExecutions()
returns child executions that are not event scope executions.
|
List<ActivityExecution> |
ModificationObserverBehavior.initializeScope(ActivityExecution scopeExecution,
int nrOfInnerInstances)
Implement to customize initialization of the scope.
|
Modifier and Type | Method and Description |
---|---|
void |
CompositeActivityBehavior.complete(ActivityExecution scopeExecution) |
void |
SubProcessActivityBehavior.completed(ActivityExecution execution)
Called after the process instance is destroyed for
this activity to perform its outgoing control flow logic.
|
void |
CompositeActivityBehavior.concurrentChildExecutionEnded(ActivityExecution scopeExecution,
ActivityExecution endedExecution)
Invoked when an execution is ended within the scope of the composite
|
ActivityExecution |
ModificationObserverBehavior.createInnerInstance(ActivityExecution scopeExecution)
Returns an execution that can be used to execute an activity within that scope.
|
void |
ModificationObserverBehavior.destroyInnerInstance(ActivityExecution concurrentExecution)
implement to destroy an execution in this scope and handle the scope's reorganization
(e.g.
|
void |
ActivityBehavior.execute(ActivityExecution execution) |
List<ActivityExecution> |
ModificationObserverBehavior.initializeScope(ActivityExecution scopeExecution,
int nrOfInnerInstances)
Implement to customize initialization of the scope.
|
void |
MigrationObserverBehavior.migrateScope(ActivityExecution scopeExecution)
Implement to perform activity-specific migration behavior that is not
covered by the regular migration procedure.
|
void |
SubProcessActivityBehavior.passOutputVariables(ActivityExecution targetExecution,
VariableScope calledElementInstance)
Pass the output variables from the process instance of the subprocess to the given execution.
|
void |
SignallableActivityBehavior.signal(ActivityExecution execution,
String signalEvent,
Object signalData) |
Modifier and Type | Method and Description |
---|---|
void |
ActivityExecution.leaveActivityViaTransitions(List<PvmTransition> outgoingTransitions,
List<? extends ActivityExecution> joinedExecutions)
Takes the given outgoing transitions, and potentially reusing
the given list of executions that were previously joined.
|
Modifier and Type | Class and Description |
---|---|
class |
ExecutionImpl |
class |
PvmExecutionImpl |
Modifier and Type | Method and Description |
---|---|
List<ActivityExecution> |
PvmExecutionImpl.findInactiveChildExecutions(PvmActivity activity) |
List<ActivityExecution> |
PvmExecutionImpl.findInactiveConcurrentExecutions(PvmActivity activity) |
Modifier and Type | Method and Description |
---|---|
static boolean |
LegacyBehavior.eventSubprocessComplete(ActivityExecution scopeExecution) |
static boolean |
LegacyBehavior.eventSubprocessConcurrentChildExecutionEnded(ActivityExecution scopeExecution,
ActivityExecution endedExecution) |
protected static boolean |
LegacyBehavior.isLegacyBehaviorRequired(ActivityExecution scopeExecution)
This method
|
Modifier and Type | Method and Description |
---|---|
void |
PvmExecutionImpl.leaveActivityViaTransitions(List<PvmTransition> _transitions,
List<? extends ActivityExecution> _recyclableExecutions) |
Modifier and Type | Method and Description |
---|---|
ActivityExecution |
ActivityExecutionTuple.getExecution() |
Modifier and Type | Method and Description |
---|---|
protected static ActivityExecutionTuple |
ActivityExecutionHierarchyWalker.createTupel(ActivityExecution execution) |
protected static PvmScope |
ActivityExecutionHierarchyWalker.getCurrentFlowScope(ActivityExecution execution) |
protected boolean |
OutputVariablesPropagator.isProcessInstanceOfSubprocess(ActivityExecution execution) |
void |
ActivityExecutionMappingCollector.visit(ActivityExecution execution) |
void |
OutputVariablesPropagator.visit(ActivityExecution execution) |
Modifier and Type | Method and Description |
---|---|
ReferenceWalker<ActivityExecutionTuple> |
ActivityExecutionHierarchyWalker.addExecutionPostVisitor(TreeVisitor<ActivityExecution> visitor) |
ReferenceWalker<ActivityExecutionTuple> |
ActivityExecutionHierarchyWalker.addExecutionPreVisitor(TreeVisitor<ActivityExecution> visitor) |
Constructor and Description |
---|
ActivityExecutionHierarchyWalker(ActivityExecution execution) |
ActivityExecutionMappingCollector(ActivityExecution execution) |
ActivityExecutionTuple(PvmScope scope,
ActivityExecution execution) |
Modifier and Type | Method and Description |
---|---|
void |
ActivitiStateHandlerRegistry.execute(ActivityExecution execution) |
void |
ActivitiStateHandlerRegistry.signal(ActivityExecution execution,
String signalName,
Object data) |
Modifier and Type | Method and Description |
---|---|
protected void |
ServiceTaskConnectorActivityBehavior.applyInputParameters(ActivityExecution execution,
org.camunda.connect.spi.ConnectorRequest<?> request) |
protected void |
ServiceTaskConnectorActivityBehavior.applyOutputParameters(ActivityExecution execution,
org.camunda.connect.spi.ConnectorResponse response) |
void |
ServiceTaskConnectorActivityBehavior.execute(ActivityExecution execution) |
Copyright © 2019. All rights reserved.