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

Class ActivityInstanceJobHandler

java.lang.Object

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

All Implemented Interfaces:

MigratingDependentInstanceParseHandler<MigratingActivityInstance,List<JobEntity>>

public class ActivityInstanceJobHandler
extends Object
implements MigratingDependentInstanceParseHandler<MigratingActivityInstance,List<JobEntity>>

Author:

Thorben Lindhauer

Constructor Summary

Constructors

Constructor and Description
ActivityInstanceJobHandler()

Method Summary

Modifier and Type	Method and Description
protected void	addEmergingTimeoutListenerJobs(MigratingInstanceParseContext parseContext, MigratingActivityInstance activityInstance, Map<String,Map<String,TimerDeclarationImpl>> sourceTimeoutListenerDeclarationsInEventScope, Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope)
protected void	addEmergingTimerJobs(MigratingInstanceParseContext parseContext, MigratingActivityInstance activityInstance, Map<String,TimerDeclarationImpl> sourceTimerDeclarationsInEventScope, Map<String,TimerDeclarationImpl> targetTimerDeclarationsInEventScope)
protected TimerDeclarationImpl	getTargetTimerDeclaration(JobEntity job, JobHandlerConfiguration jobHandlerConfiguration, String targetActivity, Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope, Map<String,TimerDeclarationImpl> targetTimerDeclarationsInEventScope)
void	handle(MigratingInstanceParseContext parseContext, MigratingActivityInstance activityInstance, List<JobEntity> elements)
protected boolean	isNonInterruptingTimeoutListenerTriggeredAlready(MigratingInstanceParseContext parseContext, Map<String,Map<String,TimerDeclarationImpl>> sourceTimeoutListenerDeclarationsInEventScope, Map.Entry<String,TimerDeclarationImpl> targetTimerDeclarationEntry)
protected boolean	isNonInterruptingTimerTriggeredAlready(MigratingInstanceParseContext parseContext, Map<String,TimerDeclarationImpl> sourceTimerDeclarationsInEventScope, TimerDeclarationImpl targetTimerDeclaration)
protected static boolean	isNoTimeoutListenerOrMigrates(JobEntity job, JobHandlerConfiguration jobHandlerConfiguration, String targetActivity, Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope)
protected static boolean	isTimeoutListenerJobInTargetScope(JobHandlerConfiguration jobHandlerConfiguration, String targetActivity, Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope)
protected static boolean	isTimerJob(JobEntity job)
protected static TimerDeclarationImpl	removeTimeoutListenerJobFromTargetScope(JobHandlerConfiguration jobHandlerConfiguration, String targetActivity, Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope)

Methods inherited from class java.lang.Object

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

Constructor Detail

ActivityInstanceJobHandler

public ActivityInstanceJobHandler()

Method Detail

handle

public void handle(MigratingInstanceParseContext parseContext,
                   MigratingActivityInstance activityInstance,
                   List<JobEntity> elements)

Specified by:

handle in interface MigratingDependentInstanceParseHandler<MigratingActivityInstance,List<JobEntity>>

getTargetTimerDeclaration

protected TimerDeclarationImpl getTargetTimerDeclaration(JobEntity job,
                                                         JobHandlerConfiguration jobHandlerConfiguration,
                                                         String targetActivity,
                                                         Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope,
                                                         Map<String,TimerDeclarationImpl> targetTimerDeclarationsInEventScope)

isTimerJob

protected static boolean isTimerJob(JobEntity job)

isNoTimeoutListenerOrMigrates

protected static boolean isNoTimeoutListenerOrMigrates(JobEntity job,
                                                       JobHandlerConfiguration jobHandlerConfiguration,
                                                       String targetActivity,
                                                       Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope)

isTimeoutListenerJobInTargetScope

protected static boolean isTimeoutListenerJobInTargetScope(JobHandlerConfiguration jobHandlerConfiguration,
                                                           String targetActivity,
                                                           Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope)

removeTimeoutListenerJobFromTargetScope

protected static TimerDeclarationImpl removeTimeoutListenerJobFromTargetScope(JobHandlerConfiguration jobHandlerConfiguration,
                                                                              String targetActivity,
                                                                              Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope)

addEmergingTimerJobs

protected void addEmergingTimerJobs(MigratingInstanceParseContext parseContext,
                                    MigratingActivityInstance activityInstance,
                                    Map<String,TimerDeclarationImpl> sourceTimerDeclarationsInEventScope,
                                    Map<String,TimerDeclarationImpl> targetTimerDeclarationsInEventScope)

addEmergingTimeoutListenerJobs

protected void addEmergingTimeoutListenerJobs(MigratingInstanceParseContext parseContext,
                                              MigratingActivityInstance activityInstance,
                                              Map<String,Map<String,TimerDeclarationImpl>> sourceTimeoutListenerDeclarationsInEventScope,
                                              Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope)

isNonInterruptingTimerTriggeredAlready

protected boolean isNonInterruptingTimerTriggeredAlready(MigratingInstanceParseContext parseContext,
                                                         Map<String,TimerDeclarationImpl> sourceTimerDeclarationsInEventScope,
                                                         TimerDeclarationImpl targetTimerDeclaration)

isNonInterruptingTimeoutListenerTriggeredAlready

protected boolean isNonInterruptingTimeoutListenerTriggeredAlready(MigratingInstanceParseContext parseContext,
                                                                   Map<String,Map<String,TimerDeclarationImpl>> sourceTimeoutListenerDeclarationsInEventScope,
                                                                   Map.Entry<String,TimerDeclarationImpl> targetTimerDeclarationEntry)