org.camunda.bpm.engine.impl.cmd

Class GetActivityInstanceCmd

java.lang.Object

org.camunda.bpm.engine.impl.cmd.GetActivityInstanceCmd

All Implemented Interfaces:

Command<ActivityInstance>

public class GetActivityInstanceCmd
extends Object
implements Command<ActivityInstance>

Creates an activity instance tree according to the following strategy:

• Event scope executions are not considered at all
• For every leaf execution, generate an activity/transition instance; the activity instance id is set in the leaf execution and the parent instance id is set in the parent execution
• For every non-leaf scope execution, generate an activity instance; the activity instance id is always set in the parent execution and the parent activity instance id is always set in the parent's parent (because of tree compactation, we ensure that an activity instance id for a scope activity is always stored in the corresponding scope execution's parent, unless the execution is a leaf)
• Compensation is an exception to the above procedure: A compensation throw event is not a scope, however the compensating executions are added as child executions of the (probably non-scope) execution executing the throw event. Logically, the compensating executions are children of the scope execution the throwing event is executed in. Due to this oddity, the activity instance id are stored on different executions

Author:

Thorben Lindhauer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GetActivityInstanceCmd.ExecutionIdComparator

Field Summary

Fields

Modifier and Type	Field and Description
protected String	processInstanceId

Constructor Summary

Constructors

Constructor and Description
GetActivityInstanceCmd(String processInstanceId)

Method Summary

Modifier and Type	Method and Description
protected void	checkGetActivityInstance(String processInstanceId, CommandContext commandContext)
protected ActivityInstanceImpl	createActivityInstance(PvmExecutionImpl scopeExecution, ScopeImpl scope, String activityInstanceId, String parentActivityInstanceId, Map<String,List<String>> incidentsByExecution)
protected TransitionInstanceImpl	createTransitionInstance(PvmExecutionImpl execution, Map<String,List<String>> incidentsByExecution)
ActivityInstance	execute(CommandContext commandContext)
protected List<ExecutionEntity>	filterLeaves(List<ExecutionEntity> executionList)
protected List<ExecutionEntity>	filterNonEventScopeExecutions(List<ExecutionEntity> executionList)
protected ExecutionEntity	filterProcessInstance(List<ExecutionEntity> executionList)
protected List<String>	getIncidentList(Map<String,List<String>> incidents, PvmExecutionImpl execution)
protected Map<String,List<String>>	groupIncidentIdsByExecutionId(CommandContext commandContext)
protected void	loadChildExecutionsFromCache(ExecutionEntity execution, List<ExecutionEntity> childExecutions) Loads all executions that are part of this process instance tree from the dbSqlSession cache.
protected List<ExecutionEntity>	loadFromDb(String processInstanceId, CommandContext commandContext)
protected List<ExecutionEntity>	loadProcessInstance(String processInstanceId, CommandContext commandContext)
protected void	orderById(List<ExecutionEntity> leaves)
protected void	populateChildInstances(Map<String,ActivityInstanceImpl> activityInstances, Map<String,TransitionInstanceImpl> transitionInstances)
protected <S,T> void	putListElement(Map<S,List<T>> mapOfLists, S key, T listElement)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

processInstanceId

protected String processInstanceId

Constructor Detail

GetActivityInstanceCmd

public GetActivityInstanceCmd(String processInstanceId)

Method Detail

execute

public ActivityInstance execute(CommandContext commandContext)

Specified by:

execute in interface Command<ActivityInstance>

checkGetActivityInstance

protected void checkGetActivityInstance(String processInstanceId,
                                        CommandContext commandContext)

orderById

protected void orderById(List<ExecutionEntity> leaves)

createActivityInstance

protected ActivityInstanceImpl createActivityInstance(PvmExecutionImpl scopeExecution,
                                                      ScopeImpl scope,
                                                      String activityInstanceId,
                                                      String parentActivityInstanceId,
                                                      Map<String,List<String>> incidentsByExecution)

createTransitionInstance

protected TransitionInstanceImpl createTransitionInstance(PvmExecutionImpl execution,
                                                          Map<String,List<String>> incidentsByExecution)

populateChildInstances

protected void populateChildInstances(Map<String,ActivityInstanceImpl> activityInstances,
                                      Map<String,TransitionInstanceImpl> transitionInstances)

putListElement

protected <S,T> void putListElement(Map<S,List<T>> mapOfLists,
                                    S key,
                                    T listElement)

filterProcessInstance

protected ExecutionEntity filterProcessInstance(List<ExecutionEntity> executionList)

filterLeaves

protected List<ExecutionEntity> filterLeaves(List<ExecutionEntity> executionList)

filterNonEventScopeExecutions

protected List<ExecutionEntity> filterNonEventScopeExecutions(List<ExecutionEntity> executionList)

loadProcessInstance

protected List<ExecutionEntity> loadProcessInstance(String processInstanceId,
                                                    CommandContext commandContext)

loadFromDb

protected List<ExecutionEntity> loadFromDb(String processInstanceId,
                                           CommandContext commandContext)

loadChildExecutionsFromCache

protected void loadChildExecutionsFromCache(ExecutionEntity execution,
                                            List<ExecutionEntity> childExecutions)

Loads all executions that are part of this process instance tree from the dbSqlSession cache. (optionally querying the db if a child is not already loaded.

Parameters:

execution - the current root execution (already contained in childExecutions)

childExecutions - the list in which all child executions should be collected

groupIncidentIdsByExecutionId

protected Map<String,List<String>> groupIncidentIdsByExecutionId(CommandContext commandContext)

getIncidentList

protected List<String> getIncidentList(Map<String,List<String>> incidents,
                                       PvmExecutionImpl execution)