Package org.camunda.bpm.engine.impl.jobexecutor

Class JobDeclaration<S,T extends JobEntity>

java.lang.Object

org.camunda.bpm.engine.impl.jobexecutor.JobDeclaration<S,T>

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

BatchJobDeclaration, BatchMonitorJobDeclaration, BatchSeedJobDeclaration, EventSubscriptionJobDeclaration, HistoryCleanupJobDeclaration, MessageJobDeclaration, TimerDeclarationImpl

public abstract class JobDeclaration<S,T extends JobEntity>
extends java.lang.Object
implements java.io.Serializable

A job declaration is associated with an activity in the process definition graph. It provides data about jobs which are to be created when executing this activity. It also acts as a factory for new Job Instances.

Jobs are of a type T and are created in the context of type S (e.g. an execution or an event subscription). An instance of the context class is handed in when a job is created.

Author:

Daniel Meyer

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected ActivityImpl	activity
protected boolean	exclusive
protected java.lang.String	jobConfiguration
protected java.lang.String	jobDefinitionId	the id of the associated persistent jobDefinitionId
protected JobHandlerConfiguration	jobHandlerConfiguration
protected java.lang.String	jobHandlerType
protected ParameterValueProvider	jobPriorityProvider

Constructor Summary

Constructors

Constructor	Description
JobDeclaration(java.lang.String jobHandlerType)

Method Summary

Modifier and Type	Method	Description
T	createJobInstance(S context)
ActivityImpl	getActivity()
java.lang.String	getActivityId()
java.lang.String	getJobConfiguration()
java.lang.String	getJobDefinitionId()
java.lang.String	getJobHandlerType()
ParameterValueProvider	getJobPriorityProvider()
ProcessDefinitionImpl	getProcessDefinition()
boolean	isExclusive()
protected abstract T	newJobInstance(S context)
protected void	postInitialize(S context, T job)	general callback to override any configuration after the defaults have been applied
T	reconfigure(S context, T job)	Re-initialize configuration part.
java.util.Date	resolveDueDate(S context)
protected boolean	resolveExclusive(S context)
protected abstract ExecutionEntity	resolveExecution(S context)	Returns the execution in which context the job is created.
protected java.lang.String	resolveJobDefinitionId(S context)
protected JobHandler	resolveJobHandler()
protected abstract JobHandlerConfiguration	resolveJobHandlerConfiguration(S context)
protected java.lang.String	resolveJobHandlerType(S context)
protected int	resolveRetries(S context)
void	setActivity(ActivityImpl activity)
void	setExclusive(boolean exclusive)
void	setJobConfiguration(java.lang.String jobConfiguration)
void	setJobDefinitionId(java.lang.String jobDefinitionId)
void	setJobPriorityProvider(ParameterValueProvider jobPriorityProvider)

Methods inherited from class java.lang.Object

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

Field Detail

jobDefinitionId

protected java.lang.String jobDefinitionId

the id of the associated persistent jobDefinitionId

jobHandlerType

protected java.lang.String jobHandlerType

jobHandlerConfiguration

protected JobHandlerConfiguration jobHandlerConfiguration

jobConfiguration

protected java.lang.String jobConfiguration

exclusive

protected boolean exclusive

activity

protected ActivityImpl activity

jobPriorityProvider

protected ParameterValueProvider jobPriorityProvider

Constructor Detail

JobDeclaration

public JobDeclaration(java.lang.String jobHandlerType)

Method Detail

createJobInstance

public T createJobInstance(S context)

Returns:

the created Job instances

reconfigure

public T reconfigure(S context,
                     T job)

Re-initialize configuration part.

postInitialize

protected void postInitialize(S context,
                              T job)

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

resolveExecution

protected abstract ExecutionEntity resolveExecution(S context)

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.

newJobInstance

protected abstract T newJobInstance(S context)

getJobDefinitionId

public java.lang.String getJobDefinitionId()

resolveJobDefinitionId

protected java.lang.String resolveJobDefinitionId(S context)

setJobDefinitionId

public void setJobDefinitionId(java.lang.String jobDefinitionId)

getJobHandlerType

public java.lang.String getJobHandlerType()

resolveJobHandler

protected JobHandler resolveJobHandler()

resolveJobHandlerType

protected java.lang.String resolveJobHandlerType(S context)

resolveJobHandlerConfiguration

protected abstract JobHandlerConfiguration resolveJobHandlerConfiguration(S context)

resolveExclusive

protected boolean resolveExclusive(S context)

resolveRetries

protected int resolveRetries(S context)

resolveDueDate

public java.util.Date resolveDueDate(S context)

isExclusive

public boolean isExclusive()

setExclusive

public void setExclusive(boolean exclusive)

getActivityId

public java.lang.String getActivityId()

getActivity

public ActivityImpl getActivity()

setActivity

public void setActivity(ActivityImpl activity)

getProcessDefinition

public ProcessDefinitionImpl getProcessDefinition()

getJobConfiguration

public java.lang.String getJobConfiguration()

setJobConfiguration

public void setJobConfiguration(java.lang.String jobConfiguration)

getJobPriorityProvider

public ParameterValueProvider getJobPriorityProvider()

setJobPriorityProvider

public void setJobPriorityProvider(ParameterValueProvider jobPriorityProvider)