org.camunda.bpm.engine.impl.persistence.entity

Class JobManager

java.lang.Object

org.camunda.bpm.engine.impl.persistence.AbstractManager

org.camunda.bpm.engine.impl.persistence.entity.JobManager

All Implemented Interfaces:

Session

public class JobManager
extends AbstractManager

Author:

Tom Baeyens, Daniel Meyer

Constructor Summary

Constructors

Constructor and Description
JobManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelTimers(ExecutionEntity execution)
List<JobEntity>	findExclusiveJobsToExecute(String processInstanceId)
JobEntity	findJobById(String jobId)
long	findJobCountByQueryCriteria(JobQueryImpl jobQuery)
List<Job>	findJobsByConfiguration(String jobHandlerType, String jobHandlerConfiguration)
List<Job>	findJobsByExecutionId(String executionId)
List<Job>	findJobsByQueryCriteria(JobQueryImpl jobQuery, Page page)
List<JobEntity>	findNextJobsToExecute(Page page)
List<TimerEntity>	findTimersByExecutionId(String executionId)
List<TimerEntity>	findUnlockedTimersByDuedate(Date duedate, Page page)
protected void	hintJobExecutor(JobEntity job)
void	schedule(TimerEntity timer)
void	send(MessageEntity message)
void	updateFailedJobRetriesByJobDefinitionId(String jobDefinitionId, int retries)
void	updateJobSuspensionStateById(String jobId, SuspensionState suspensionState)
void	updateJobSuspensionStateByJobDefinitionId(String jobDefinitionId, SuspensionState suspensionState)
void	updateJobSuspensionStateByProcessDefinitionId(String processDefinitionId, SuspensionState suspensionState)
void	updateJobSuspensionStateByProcessDefinitionKey(String processDefinitionKey, SuspensionState suspensionState)
void	updateJobSuspensionStateByProcessInstanceId(String processInstanceId, SuspensionState suspensionState)
void	updateStartTimerJobSuspensionStateByProcessDefinitionId(String processDefinitionId, SuspensionState suspensionState)
void	updateStartTimerJobSuspensionStateByProcessDefinitionKey(String processDefinitionKey, SuspensionState suspensionState)

Methods inherited from class org.camunda.bpm.engine.impl.persistence.AbstractManager

close, delete, flush, getAttachmentManager, getByteArrayManager, getDbSqlSession, getDeploymentManager, getHistoricActivityInstanceManager, getHistoricDetailManager, getHistoricProcessInstanceManager, getHistoricTaskInstanceManager, getIdentityInfoManager, getIdentityLinkManager, getProcessDefinitionManager, getProcessInstanceManager, getResourceManager, getSession, getTaskManager, getVariableInstanceManager, insert

Methods inherited from class java.lang.Object

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

Constructor Detail

JobManager

public JobManager()

Method Detail

send

public void send(MessageEntity message)

schedule

public void schedule(TimerEntity timer)

hintJobExecutor

protected void hintJobExecutor(JobEntity job)

cancelTimers

public void cancelTimers(ExecutionEntity execution)

findJobById

public JobEntity findJobById(String jobId)

findNextJobsToExecute

public List<JobEntity> findNextJobsToExecute(Page page)

findJobsByExecutionId

public List<Job> findJobsByExecutionId(String executionId)

findExclusiveJobsToExecute

public List<JobEntity> findExclusiveJobsToExecute(String processInstanceId)

findUnlockedTimersByDuedate

public List<TimerEntity> findUnlockedTimersByDuedate(Date duedate,
                                            Page page)

findTimersByExecutionId

public List<TimerEntity> findTimersByExecutionId(String executionId)

findJobsByQueryCriteria

public List<Job> findJobsByQueryCriteria(JobQueryImpl jobQuery,
                                Page page)

findJobsByConfiguration

public List<Job> findJobsByConfiguration(String jobHandlerType,
                                String jobHandlerConfiguration)

findJobCountByQueryCriteria

public long findJobCountByQueryCriteria(JobQueryImpl jobQuery)

updateJobSuspensionStateById

public void updateJobSuspensionStateById(String jobId,
                                SuspensionState suspensionState)

updateJobSuspensionStateByJobDefinitionId

public void updateJobSuspensionStateByJobDefinitionId(String jobDefinitionId,
                                             SuspensionState suspensionState)

updateJobSuspensionStateByProcessInstanceId

public void updateJobSuspensionStateByProcessInstanceId(String processInstanceId,
                                               SuspensionState suspensionState)

updateJobSuspensionStateByProcessDefinitionId

public void updateJobSuspensionStateByProcessDefinitionId(String processDefinitionId,
                                                 SuspensionState suspensionState)

updateStartTimerJobSuspensionStateByProcessDefinitionId

public void updateStartTimerJobSuspensionStateByProcessDefinitionId(String processDefinitionId,
                                                           SuspensionState suspensionState)

updateJobSuspensionStateByProcessDefinitionKey

public void updateJobSuspensionStateByProcessDefinitionKey(String processDefinitionKey,
                                                  SuspensionState suspensionState)

updateStartTimerJobSuspensionStateByProcessDefinitionKey

public void updateStartTimerJobSuspensionStateByProcessDefinitionKey(String processDefinitionKey,
                                                            SuspensionState suspensionState)

updateFailedJobRetriesByJobDefinitionId

public void updateFailedJobRetriesByJobDefinitionId(String jobDefinitionId,
                                           int retries)