Package org.flowable.job.service.impl.persistence.entity

Interface JobInfoEntityManager<T extends JobInfoEntity>

All Superinterfaces:

EntityManager<T>

All Known Subinterfaces:

ExternalWorkerJobEntityManager, HistoryJobEntityManager, JobEntityManager, TimerJobEntityManager

All Known Implementing Classes:

ExternalWorkerJobEntityManagerImpl, HistoryJobEntityManagerImpl, JobEntityManagerImpl, JobInfoEntityManagerImpl, TimerJobEntityManagerImpl

public interface JobInfoEntityManager<T extends JobInfoEntity>
extends EntityManager<T>

Method Summary

Modifier and Type	Method	Description
void	bulkUpdateJobLockWithoutRevisionCheck(List<T> jobEntities, String lockOwner, Date lockExpirationTime)
List<T>	findExpiredJobs(List<String> enabledCategories, Page page)	Returns all JobEntity instance which are expired, which means that the lock time of the JobEntity is past a certain configurable date and is deemed to be in error.
List<T>	findJobsByExecutionId(String executionId)	Returns all JobEntity instances related to on ExecutionEntity.
List<T>	findJobsByProcessInstanceId(String processInstanceId)	Returns all JobEntity instances related to one process instance ExecutionEntity.
List<T>	findJobsToExecute(List<String> enabledCategories, Page page)	Returns JobEntity that are eligible to be executed.
default List<T>	findJobsToExecuteAndLockInBulk(List<String> enabledCategories, Page page, String lockOwner, Date lockExpirationTime)
void	resetExpiredJob(String jobId)	Resets an expired job.
void	updateJobTenantIdForDeployment(String deploymentId, String newTenantId)	Changes the tenantId for all jobs related to a given DeploymentEntity.

Methods inherited from interface org.flowable.common.engine.impl.persistence.entity.EntityManager

create, delete, delete, delete, findById, insert, insert, update, update

Method Details

findJobsToExecute

List<T> findJobsToExecute(List<String> enabledCategories,
 Page page)

Returns JobEntity that are eligible to be executed. For example used by the default AcquireJobsCmd command used by the default AcquireTimerJobsRunnable implementation to get async jobs that can be executed.

findJobsByExecutionId

List<T> findJobsByExecutionId(String executionId)

Returns all JobEntity instances related to on ExecutionEntity.

findJobsByProcessInstanceId

List<T> findJobsByProcessInstanceId(String processInstanceId)

Returns all JobEntity instances related to one process instance ExecutionEntity.

findExpiredJobs

List<T> findExpiredJobs(List<String> enabledCategories,
 Page page)

Returns all JobEntity instance which are expired, which means that the lock time of the JobEntity is past a certain configurable date and is deemed to be in error.

resetExpiredJob

void resetExpiredJob(String jobId)

Resets an expired job. These are jobs that were locked, but not completed. Resetting these will make them available for being picked up by other executors.

updateJobTenantIdForDeployment

void updateJobTenantIdForDeployment(String deploymentId,
 String newTenantId)

Changes the tenantId for all jobs related to a given DeploymentEntity.

findJobsToExecuteAndLockInBulk

default List<T> findJobsToExecuteAndLockInBulk(List<String> enabledCategories,
 Page page,
 String lockOwner,
 Date lockExpirationTime)

bulkUpdateJobLockWithoutRevisionCheck

void bulkUpdateJobLockWithoutRevisionCheck(List<T> jobEntities,
 String lockOwner,
 Date lockExpirationTime)