Package org.camunda.bpm.engine.impl.migration.instance.parser

Class MigratingInstanceParseContext

java.lang.Object

org.camunda.bpm.engine.impl.migration.instance.parser.MigratingInstanceParseContext

public class MigratingInstanceParseContext
extends java.lang.Object

Author:

Thorben Lindhauer

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Map<java.lang.String,MigratingActivityInstance>	activityInstances
protected java.util.Map<java.lang.String,MigratingEventScopeInstance>	compensationInstances
protected java.util.Collection<EventSubscriptionEntity>	eventSubscriptions
protected java.util.Collection<ExternalTaskEntity>	externalTasks
protected java.util.Collection<IncidentEntity>	incidents
protected java.util.Map<java.lang.String,java.util.List<MigrationInstruction>>	instructionsBySourceScope
protected java.util.Collection<JobEntity>	jobs
protected ActivityExecutionTreeMapping	mapping
protected java.util.Map<java.lang.String,MigratingExternalTaskInstance>	migratingExternalTasks
protected java.util.Map<java.lang.String,MigratingJobInstance>	migratingJobs
protected MigratingProcessInstance	migratingProcessInstance
protected MigratingInstanceParser	parser
protected ProcessDefinitionEntity	sourceProcessDefinition
protected java.util.Map<java.lang.String,java.util.List<JobDefinitionEntity>>	targetJobDefinitions
protected ProcessDefinitionEntity	targetProcessDefinition
protected java.util.Collection<TaskEntity>	tasks
protected java.util.Collection<VariableInstanceEntity>	variables

Constructor Summary

Constructors

Constructor	Description
MigratingInstanceParseContext(MigratingInstanceParser parser, MigrationPlan migrationPlan, ExecutionEntity processInstance, ProcessDefinitionEntity targetProcessDefinition)

Method Summary

Modifier and Type	Method	Description
void	consume(EventSubscriptionEntity eventSubscription)
void	consume(ExternalTaskEntity externalTask)
void	consume(IncidentEntity incident)
void	consume(JobEntity job)
void	consume(TaskEntity task)
void	consume(VariableInstanceEntity variableInstance)
void	ensureNoEntitiesAreLeft(java.lang.String entityName, java.util.Collection<? extends DbEntity> dbEntities, MigratingProcessInstanceValidationReportImpl processInstanceReport)
MigratingInstanceParseContext	eventSubscriptions(java.util.Collection<EventSubscriptionEntity> eventSubscriptions)
MigratingInstanceParseContext	externalTasks(java.util.Collection<ExternalTaskEntity> externalTasks)
MigrationInstruction	findSingleMigrationInstruction(java.lang.String sourceScopeId)
MigrationInstruction	getInstructionFor(java.lang.String scopeId)
ActivityExecutionTreeMapping	getMapping()
MigratingActivityInstance	getMigratingActivityInstanceById(java.lang.String activityInstanceId)
java.util.Collection<MigratingActivityInstance>	getMigratingActivityInstances()
MigratingScopeInstance	getMigratingCompensationInstanceByExecutionId(java.lang.String id)
MigratingExternalTaskInstance	getMigratingExternalTaskInstanceById(java.lang.String externalTaskId)
MigratingJobInstance	getMigratingJobInstanceById(java.lang.String jobId)
MigratingProcessInstance	getMigratingProcessInstance()
ProcessDefinitionImpl	getSourceProcessDefinition()
ActivityImpl	getTargetActivity(MigrationInstruction instruction)
JobDefinitionEntity	getTargetJobDefinition(java.lang.String activityId, java.lang.String jobHandlerType)
ProcessDefinitionImpl	getTargetProcessDefinition()
void	handleDependentActivityInstanceJobs(MigratingActivityInstance migratingInstance, java.util.List<JobEntity> jobs)
void	handleDependentEventSubscriptions(MigratingActivityInstance migratingInstance, java.util.List<EventSubscriptionEntity> eventSubscriptions)
void	handleDependentTransitionInstanceJobs(MigratingTransitionInstance migratingInstance, java.util.List<JobEntity> jobs)
void	handleDependentVariables(MigratingProcessElementInstance migratingInstance, java.util.List<VariableInstanceEntity> variables)
void	handleTransitionInstance(TransitionInstance transitionInstance)
MigratingInstanceParseContext	incidents(java.util.Collection<IncidentEntity> incidents)
MigratingInstanceParseContext	jobs(java.util.Collection<JobEntity> jobs)
protected java.util.Map<java.lang.String,java.util.List<MigrationInstruction>>	organizeInstructionsBySourceScope(MigrationPlan migrationPlan)
void	submit(MigratingActivityInstance activityInstance)
void	submit(MigratingEventScopeInstance compensationInstance)
void	submit(MigratingExternalTaskInstance externalTask)
void	submit(MigratingJobInstance job)
MigratingInstanceParseContext	targetJobDefinitions(java.util.Collection<JobDefinitionEntity> jobDefinitions)
MigratingInstanceParseContext	tasks(java.util.Collection<TaskEntity> tasks)
void	validateNoEntitiesLeft(MigratingProcessInstanceValidationReportImpl processInstanceReport)
MigratingInstanceParseContext	variables(java.util.Collection<VariableInstanceEntity> variables)

Methods inherited from class java.lang.Object

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

Field Detail

migratingProcessInstance

protected MigratingProcessInstance migratingProcessInstance

activityInstances

protected java.util.Map<java.lang.String,MigratingActivityInstance> activityInstances

compensationInstances

protected java.util.Map<java.lang.String,MigratingEventScopeInstance> compensationInstances

migratingJobs

protected java.util.Map<java.lang.String,MigratingJobInstance> migratingJobs

migratingExternalTasks

protected java.util.Map<java.lang.String,MigratingExternalTaskInstance> migratingExternalTasks

eventSubscriptions

protected java.util.Collection<EventSubscriptionEntity> eventSubscriptions

incidents

protected java.util.Collection<IncidentEntity> incidents

jobs

protected java.util.Collection<JobEntity> jobs

tasks

protected java.util.Collection<TaskEntity> tasks

externalTasks

protected java.util.Collection<ExternalTaskEntity> externalTasks

variables

protected java.util.Collection<VariableInstanceEntity> variables

sourceProcessDefinition

protected ProcessDefinitionEntity sourceProcessDefinition

targetProcessDefinition

protected ProcessDefinitionEntity targetProcessDefinition

targetJobDefinitions

protected java.util.Map<java.lang.String,java.util.List<JobDefinitionEntity>> targetJobDefinitions

mapping

protected ActivityExecutionTreeMapping mapping

instructionsBySourceScope

protected java.util.Map<java.lang.String,java.util.List<MigrationInstruction>> instructionsBySourceScope

parser

protected MigratingInstanceParser parser

Constructor Detail

MigratingInstanceParseContext

public MigratingInstanceParseContext(MigratingInstanceParser parser,
                                     MigrationPlan migrationPlan,
                                     ExecutionEntity processInstance,
                                     ProcessDefinitionEntity targetProcessDefinition)

Method Detail

jobs

public MigratingInstanceParseContext jobs(java.util.Collection<JobEntity> jobs)

incidents

public MigratingInstanceParseContext incidents(java.util.Collection<IncidentEntity> incidents)

tasks

public MigratingInstanceParseContext tasks(java.util.Collection<TaskEntity> tasks)

externalTasks

public MigratingInstanceParseContext externalTasks(java.util.Collection<ExternalTaskEntity> externalTasks)

eventSubscriptions

public MigratingInstanceParseContext eventSubscriptions(java.util.Collection<EventSubscriptionEntity> eventSubscriptions)

targetJobDefinitions

public MigratingInstanceParseContext targetJobDefinitions(java.util.Collection<JobDefinitionEntity> jobDefinitions)

variables

public MigratingInstanceParseContext variables(java.util.Collection<VariableInstanceEntity> variables)

submit

public void submit(MigratingActivityInstance activityInstance)

submit

public void submit(MigratingEventScopeInstance compensationInstance)

submit

public void submit(MigratingJobInstance job)

submit

public void submit(MigratingExternalTaskInstance externalTask)

consume

public void consume(TaskEntity task)

consume

public void consume(ExternalTaskEntity externalTask)

consume

public void consume(IncidentEntity incident)

consume

public void consume(JobEntity job)

consume

public void consume(EventSubscriptionEntity eventSubscription)

consume

public void consume(VariableInstanceEntity variableInstance)

getMigratingProcessInstance

public MigratingProcessInstance getMigratingProcessInstance()

getMigratingActivityInstances

public java.util.Collection<MigratingActivityInstance> getMigratingActivityInstances()

getSourceProcessDefinition

public ProcessDefinitionImpl getSourceProcessDefinition()

getTargetProcessDefinition

public ProcessDefinitionImpl getTargetProcessDefinition()

getTargetActivity

public ActivityImpl getTargetActivity(MigrationInstruction instruction)

getTargetJobDefinition

public JobDefinitionEntity getTargetJobDefinition(java.lang.String activityId,
                                                  java.lang.String jobHandlerType)

getMapping

public ActivityExecutionTreeMapping getMapping()

getInstructionFor

public MigrationInstruction getInstructionFor(java.lang.String scopeId)

getMigratingActivityInstanceById

public MigratingActivityInstance getMigratingActivityInstanceById(java.lang.String activityInstanceId)

getMigratingCompensationInstanceByExecutionId

public MigratingScopeInstance getMigratingCompensationInstanceByExecutionId(java.lang.String id)

getMigratingJobInstanceById

public MigratingJobInstance getMigratingJobInstanceById(java.lang.String jobId)

getMigratingExternalTaskInstanceById

public MigratingExternalTaskInstance getMigratingExternalTaskInstanceById(java.lang.String externalTaskId)

findSingleMigrationInstruction

public MigrationInstruction findSingleMigrationInstruction(java.lang.String sourceScopeId)

organizeInstructionsBySourceScope

protected java.util.Map<java.lang.String,java.util.List<MigrationInstruction>> organizeInstructionsBySourceScope(MigrationPlan migrationPlan)

handleDependentActivityInstanceJobs

public void handleDependentActivityInstanceJobs(MigratingActivityInstance migratingInstance,
                                                java.util.List<JobEntity> jobs)

handleDependentTransitionInstanceJobs

public void handleDependentTransitionInstanceJobs(MigratingTransitionInstance migratingInstance,
                                                  java.util.List<JobEntity> jobs)

handleDependentEventSubscriptions

public void handleDependentEventSubscriptions(MigratingActivityInstance migratingInstance,
                                              java.util.List<EventSubscriptionEntity> eventSubscriptions)

handleDependentVariables

public void handleDependentVariables(MigratingProcessElementInstance migratingInstance,
                                     java.util.List<VariableInstanceEntity> variables)

handleTransitionInstance

public void handleTransitionInstance(TransitionInstance transitionInstance)

validateNoEntitiesLeft

public void validateNoEntitiesLeft(MigratingProcessInstanceValidationReportImpl processInstanceReport)

ensureNoEntitiesAreLeft

public void ensureNoEntitiesAreLeft(java.lang.String entityName,
                                    java.util.Collection<? extends DbEntity> dbEntities,
                                    MigratingProcessInstanceValidationReportImpl processInstanceReport)