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
-
Method Summary
Modifier and TypeMethodDescriptionprotected 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)
-
Constructor Details
-
ActivityInstanceJobHandler
public ActivityInstanceJobHandler()
-
-
Method Details
-
handle
public void handle(MigratingInstanceParseContext parseContext, MigratingActivityInstance activityInstance, List<JobEntity> elements) - Specified by:
handle
in interfaceMigratingDependentInstanceParseHandler<MigratingActivityInstance,
List<JobEntity>>
-
getTargetTimerDeclaration
protected TimerDeclarationImpl getTargetTimerDeclaration(JobEntity job, JobHandlerConfiguration jobHandlerConfiguration, String targetActivity, Map<String, Map<String, TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope, Map<String, TimerDeclarationImpl> targetTimerDeclarationsInEventScope) -
isTimerJob
-
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)
-