Package org.operaton.bpm.engine.impl.jobexecutor

Class TimerDeclarationImpl

java.lang.Object

org.operaton.bpm.engine.impl.jobexecutor.JobDeclaration<ExecutionEntity,TimerEntity>

org.operaton.bpm.engine.impl.jobexecutor.TimerDeclarationImpl

public class TimerDeclarationImpl
extends JobDeclaration<ExecutionEntity,TimerEntity>

Author:

Tom Baeyens, Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
protected Expression	description
protected String	eventScopeActivityId
protected boolean	isInterruptingTimer
protected String	rawJobHandlerConfiguration
protected String	repeat
protected TimerDeclarationType	type

Fields inherited from class org.operaton.bpm.engine.impl.jobexecutor.JobDeclaration

activity, exclusive, jobConfiguration, jobDefinitionId, jobHandlerConfiguration, jobHandlerType, jobPriorityProvider

Constructor Summary

Constructors

Constructor	Description
TimerDeclarationImpl(Expression expression, TimerDeclarationType type, String jobHandlerType)

Method Summary

Modifier and Type	Method	Description
TimerEntity	createStartTimerInstance(String deploymentId)
TimerEntity	createTimer(String deploymentId)
TimerEntity	createTimer(ExecutionEntity execution)
TimerEntity	createTimerInstance(ExecutionEntity execution)
static Map<String,TimerDeclarationImpl>	getDeclarationsForScope(PvmScope scope)
String	getEventScopeActivityId()
String	getRepeat()
static Map<String,Map<String,TimerDeclarationImpl>>	getTimeoutListenerDeclarationsForScope(PvmScope scope)
protected void	initializeConfiguration(ExecutionEntity context, TimerEntity job)
boolean	isInterruptingTimer()
protected TimerEntity	newJobInstance(ExecutionEntity execution)
protected void	postInitialize(ExecutionEntity execution, TimerEntity timer)	general callback to override any configuration after the defaults have been applied
protected String	prepareRepeat(String dueDate)
String	resolveAndSetDuedate(ExecutionEntity context, TimerEntity job, boolean creationDateBased)
protected ExecutionEntity	resolveExecution(ExecutionEntity context)	Returns the execution in which context the job is created.
protected JobHandlerConfiguration	resolveJobHandlerConfiguration(ExecutionEntity context)
protected void	scheduleTimer(TimerEntity timer)
void	setEventScopeActivityId(String eventScopeActivityId)
void	setInterruptingTimer(boolean isInterruptingTimer)
void	setRawJobHandlerConfiguration(String rawJobHandlerConfiguration)
void	updateJob(TimerEntity timer)

Methods inherited from class org.operaton.bpm.engine.impl.jobexecutor.JobDeclaration

createJobInstance, getActivity, getActivityId, getJobConfiguration, getJobDefinitionId, getJobHandlerType, getJobPriorityProvider, getProcessDefinition, isExclusive, reconfigure, resolveDueDate, resolveExclusive, resolveJobDefinitionId, resolveJobHandler, resolveJobHandlerType, resolveRetries, setActivity, setExclusive, setJobConfiguration, setJobDefinitionId, setJobPriorityProvider

Methods inherited from class java.lang.Object

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

Field Details

description

protected Expression description

type

protected TimerDeclarationType type

repeat

protected String repeat

isInterruptingTimer

protected boolean isInterruptingTimer

eventScopeActivityId

protected String eventScopeActivityId

rawJobHandlerConfiguration

protected String rawJobHandlerConfiguration

Constructor Details

TimerDeclarationImpl

public TimerDeclarationImpl(Expression expression,
 TimerDeclarationType type,
 String jobHandlerType)

Method Details

isInterruptingTimer

public boolean isInterruptingTimer()

setInterruptingTimer

public void setInterruptingTimer(boolean isInterruptingTimer)

getRepeat

public String getRepeat()

setEventScopeActivityId

public void setEventScopeActivityId(String eventScopeActivityId)

getEventScopeActivityId

public String getEventScopeActivityId()

newJobInstance

protected TimerEntity newJobInstance(ExecutionEntity execution)

Specified by:

newJobInstance in class JobDeclaration<ExecutionEntity,TimerEntity>

setRawJobHandlerConfiguration

public void setRawJobHandlerConfiguration(String rawJobHandlerConfiguration)

updateJob

public void updateJob(TimerEntity timer)

initializeConfiguration

protected void initializeConfiguration(ExecutionEntity context,
 TimerEntity job)

resolveAndSetDuedate

public String resolveAndSetDuedate(ExecutionEntity context,
 TimerEntity job,
 boolean creationDateBased)

postInitialize

protected void postInitialize(ExecutionEntity execution,
 TimerEntity timer)

Description copied from class: JobDeclaration

general callback to override any configuration after the defaults have been applied

Overrides:

postInitialize in class JobDeclaration<ExecutionEntity,TimerEntity>

prepareRepeat

protected String prepareRepeat(String dueDate)

createTimerInstance

public TimerEntity createTimerInstance(ExecutionEntity execution)

createStartTimerInstance

public TimerEntity createStartTimerInstance(String deploymentId)

createTimer

public TimerEntity createTimer(String deploymentId)

createTimer

public TimerEntity createTimer(ExecutionEntity execution)

scheduleTimer

protected void scheduleTimer(TimerEntity timer)

resolveExecution

protected ExecutionEntity resolveExecution(ExecutionEntity context)

Description copied from class: JobDeclaration

Returns the execution in which context the job is created. The execution is used to determine the job's priority based on a BPMN activity the execution is currently executing. May be null.

Specified by:

resolveExecution in class JobDeclaration<ExecutionEntity,TimerEntity>

resolveJobHandlerConfiguration

protected JobHandlerConfiguration resolveJobHandlerConfiguration(ExecutionEntity context)

Specified by:

resolveJobHandlerConfiguration in class JobDeclaration<ExecutionEntity,TimerEntity>

getDeclarationsForScope

public static Map<String,TimerDeclarationImpl> getDeclarationsForScope(PvmScope scope)

Returns:

all timers declared in the given scope

getTimeoutListenerDeclarationsForScope

public static Map<String,Map<String,TimerDeclarationImpl>> getTimeoutListenerDeclarationsForScope(PvmScope scope)

Returns:

all timeout listeners declared in the given scope