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)

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)