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

Class TimerJobEntityManagerImpl

java.lang.Object

org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager<EntityImpl,DM>

org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager<JobServiceConfiguration,EntityImpl,DM>

org.flowable.job.service.impl.persistence.entity.AbstractJobServiceEngineEntityManager<T,DM>

org.flowable.job.service.impl.persistence.entity.JobInfoEntityManagerImpl<TimerJobEntity,TimerJobDataManager>

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

All Implemented Interfaces:

EntityManager<TimerJobEntity>, JobInfoEntityManager<TimerJobEntity>, TimerJobEntityManager

public class TimerJobEntityManagerImpl
extends JobInfoEntityManagerImpl<TimerJobEntity,TimerJobDataManager>
implements TimerJobEntityManager

Author:

Tijs Rademakers

Field Summary

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager

serviceConfiguration

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

dataManager, engineType

Constructor Summary

Constructors

Constructor	Description
TimerJobEntityManagerImpl(JobServiceConfiguration jobServiceConfiguration, TimerJobDataManager jobDataManager)

Method Summary

Modifier and Type	Method	Description
void	bulkDeleteTimerJobsWithoutRevisionCheck(List<TimerJobEntity> timerJobEntities)
void	bulkUpdateJobLockWithoutRevisionCheck(List<TimerJobEntity> timerJobEntities, String lockOwner, Date lockExpirationTime)
protected Date	calculateNextTimer(JobEntity timerEntity, VariableScope variableScope)
protected int	calculateRepeatValue(JobEntity timerEntity)
TimerJobEntity	createAndCalculateNextTimer(JobEntity timerEntity, VariableScope variableScope)	Creates a new TimerJobEntity, typically when a timer is used in a repeating way.
protected TimerJobEntity	createTimer(JobEntity te)
void	delete(TimerJobEntity jobEntity)
void	delete(TimerJobEntity jobEntity, boolean fireDeleteEvent)
protected boolean	doInsert(TimerJobEntity jobEntity, boolean fireCreateEvent)
TimerJobEntity	findJobByCorrelationId(String correlationId)	Find the timer job with the given correlation id.
long	findJobCountByQueryCriteria(TimerJobQueryImpl jobQuery)	Same as TimerJobEntityManager.findJobsByQueryCriteria(TimerJobQueryImpl), but only returns a count and not the instances itself.
List<TimerJobEntity>	findJobsByExecutionId(String id)	Returns all JobEntity instances related to on ExecutionEntity.
List<TimerJobEntity>	findJobsByProcessInstanceId(String id)	Returns all JobEntity instances related to one process instance ExecutionEntity.
List<Job>	findJobsByQueryCriteria(TimerJobQueryImpl jobQuery)	Executes a JobQueryImpl and returns the matching TimerJobEntity instances.
List<TimerJobEntity>	findJobsByScopeIdAndSubScopeId(String scopeId, String subScopeId)	Returns all TimerJobEntity for the given scope and subscope.
List<TimerJobEntity>	findJobsByTypeAndProcessDefinitionId(String jobHandlerType, String processDefinitionId)	Returns the TimerJobEntity for a given process definition.
List<TimerJobEntity>	findJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType, String processDefinitionKey, String tenantId)	The same as TimerJobEntityManager.findJobsByTypeAndProcessDefinitionId(String, String), but by key and for a specific tenantId.
List<TimerJobEntity>	findJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType, String processDefinitionKey)	The same as TimerJobEntityManager.findJobsByTypeAndProcessDefinitionId(String, String), but by key and specifically for the 'no tenant' mode.
void	insert(TimerJobEntity jobEntity)
void	insert(TimerJobEntity jobEntity, boolean fireCreateEvent)
boolean	insertTimerJobEntity(TimerJobEntity timerJobEntity)	Insert the TimerJobEntity, similar to insert(TimerJobEntity), but returns a boolean in case the insert did not go through.
protected boolean	isValidTime(JobEntity timerEntity, Date newTimerDate, VariableScope variableScope)
protected void	setNewRepeat(JobEntity timerEntity, int newRepeatValue)
void	updateJobTenantIdForDeployment(String deploymentId, String newTenantId)	Changes the tenantId for all jobs related to a given DeploymentEntity.

Methods inherited from class org.flowable.job.service.impl.persistence.entity.JobInfoEntityManagerImpl

findExpiredJobs, findJobsToExecute, resetExpiredJob

Methods inherited from class org.flowable.job.service.impl.persistence.entity.AbstractJobServiceEngineEntityManager

bulkDeleteByteArraysById, createEntityEvent, deleteByteArrayRef

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager

getClock, getEventDispatcher, getServiceConfiguration

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

create, delete, findById, fireEntityDeletedEvent, fireEntityInsertedEvent, fireEntityUpdatedEvent, getDataManager, setDataManager, update, update

Methods inherited from class java.lang.Object

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

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

create, delete, findById, update, update

Methods inherited from interface org.flowable.job.service.impl.persistence.entity.JobInfoEntityManager

findExpiredJobs, findJobsToExecute, findJobsToExecuteAndLockInBulk, resetExpiredJob

Constructor Details

TimerJobEntityManagerImpl

public TimerJobEntityManagerImpl(JobServiceConfiguration jobServiceConfiguration,
 TimerJobDataManager jobDataManager)

Method Details

createAndCalculateNextTimer

public TimerJobEntity createAndCalculateNextTimer(JobEntity timerEntity,
 VariableScope variableScope)

Description copied from interface: TimerJobEntityManager

Creates a new TimerJobEntity, typically when a timer is used in a repeating way. The returns TimerJobEntity is not yet inserted.

Returns null if the timer has finished its repetitions.

Specified by:

createAndCalculateNextTimer in interface TimerJobEntityManager

findJobByCorrelationId

public TimerJobEntity findJobByCorrelationId(String correlationId)

Description copied from interface: TimerJobEntityManager

Find the timer job with the given correlation id.

Specified by:

findJobByCorrelationId in interface TimerJobEntityManager

findJobsByTypeAndProcessDefinitionId

public List<TimerJobEntity> findJobsByTypeAndProcessDefinitionId(String jobHandlerType,
 String processDefinitionId)

Description copied from interface: TimerJobEntityManager

Returns the TimerJobEntity for a given process definition.

This is for example used when deleting a process definition: it finds the TimerJobEntity representing the timer start events.

Specified by:

findJobsByTypeAndProcessDefinitionId in interface TimerJobEntityManager

findJobsByTypeAndProcessDefinitionKeyNoTenantId

public List<TimerJobEntity> findJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType,
 String processDefinitionKey)

Description copied from interface: TimerJobEntityManager

The same as TimerJobEntityManager.findJobsByTypeAndProcessDefinitionId(String, String), but by key and specifically for the 'no tenant' mode.

Specified by:

findJobsByTypeAndProcessDefinitionKeyNoTenantId in interface TimerJobEntityManager

findJobsByTypeAndProcessDefinitionKeyAndTenantId

public List<TimerJobEntity> findJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType,
 String processDefinitionKey,
 String tenantId)

Description copied from interface: TimerJobEntityManager

The same as TimerJobEntityManager.findJobsByTypeAndProcessDefinitionId(String, String), but by key and for a specific tenantId.

Specified by:

findJobsByTypeAndProcessDefinitionKeyAndTenantId in interface TimerJobEntityManager

findJobsByExecutionId

public List<TimerJobEntity> findJobsByExecutionId(String id)

Description copied from interface: JobInfoEntityManager

Returns all JobEntity instances related to on ExecutionEntity.

Specified by:

findJobsByExecutionId in interface JobInfoEntityManager<TimerJobEntity>

Overrides:

findJobsByExecutionId in class JobInfoEntityManagerImpl<TimerJobEntity,TimerJobDataManager>

findJobsByProcessInstanceId

public List<TimerJobEntity> findJobsByProcessInstanceId(String id)

Description copied from interface: JobInfoEntityManager

Returns all JobEntity instances related to one process instance ExecutionEntity.

Specified by:

findJobsByProcessInstanceId in interface JobInfoEntityManager<TimerJobEntity>

Overrides:

findJobsByProcessInstanceId in class JobInfoEntityManagerImpl<TimerJobEntity,TimerJobDataManager>

findJobsByScopeIdAndSubScopeId

public List<TimerJobEntity> findJobsByScopeIdAndSubScopeId(String scopeId,
 String subScopeId)

Description copied from interface: TimerJobEntityManager

Returns all TimerJobEntity for the given scope and subscope.

Specified by:

findJobsByScopeIdAndSubScopeId in interface TimerJobEntityManager

findJobsByQueryCriteria

public List<Job> findJobsByQueryCriteria(TimerJobQueryImpl jobQuery)

Description copied from interface: TimerJobEntityManager

Executes a JobQueryImpl and returns the matching TimerJobEntity instances.

Specified by:

findJobsByQueryCriteria in interface TimerJobEntityManager

findJobCountByQueryCriteria

public long findJobCountByQueryCriteria(TimerJobQueryImpl jobQuery)

Description copied from interface: TimerJobEntityManager

Same as TimerJobEntityManager.findJobsByQueryCriteria(TimerJobQueryImpl), but only returns a count and not the instances itself.

Specified by:

findJobCountByQueryCriteria in interface TimerJobEntityManager

updateJobTenantIdForDeployment

public void updateJobTenantIdForDeployment(String deploymentId,
 String newTenantId)

Description copied from interface: JobInfoEntityManager

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

Specified by:

updateJobTenantIdForDeployment in interface JobInfoEntityManager<TimerJobEntity>

Overrides:

updateJobTenantIdForDeployment in class JobInfoEntityManagerImpl<TimerJobEntity,TimerJobDataManager>

insertTimerJobEntity

public boolean insertTimerJobEntity(TimerJobEntity timerJobEntity)

Description copied from interface: TimerJobEntityManager

Insert the TimerJobEntity, similar to insert(TimerJobEntity), but returns a boolean in case the insert did not go through. This could happen if the execution related to the TimerJobEntity has been removed (for example due to a task complete for a timer boundary on that task).

Specified by:

insertTimerJobEntity in interface TimerJobEntityManager

insert

public void insert(TimerJobEntity jobEntity)

Specified by:

insert in interface EntityManager<TimerJobEntity>

Overrides:

insert in class AbstractEntityManager<TimerJobEntity,TimerJobDataManager>

insert

public void insert(TimerJobEntity jobEntity,
 boolean fireCreateEvent)

Specified by:

insert in interface EntityManager<TimerJobEntity>

Overrides:

insert in class AbstractEntityManager<TimerJobEntity,TimerJobDataManager>

doInsert

protected boolean doInsert(TimerJobEntity jobEntity,
 boolean fireCreateEvent)

delete

public void delete(TimerJobEntity jobEntity)

Specified by:

delete in interface EntityManager<TimerJobEntity>

Overrides:

delete in class AbstractEntityManager<TimerJobEntity,TimerJobDataManager>

delete

public void delete(TimerJobEntity jobEntity,
 boolean fireDeleteEvent)

Specified by:

delete in interface EntityManager<TimerJobEntity>

Overrides:

delete in class AbstractEntityManager<TimerJobEntity,TimerJobDataManager>

bulkUpdateJobLockWithoutRevisionCheck

public void bulkUpdateJobLockWithoutRevisionCheck(List<TimerJobEntity> timerJobEntities,
 String lockOwner,
 Date lockExpirationTime)

Specified by:

bulkUpdateJobLockWithoutRevisionCheck in interface JobInfoEntityManager<TimerJobEntity>

Overrides:

bulkUpdateJobLockWithoutRevisionCheck in class JobInfoEntityManagerImpl<TimerJobEntity,TimerJobDataManager>

bulkDeleteTimerJobsWithoutRevisionCheck

public void bulkDeleteTimerJobsWithoutRevisionCheck(List<TimerJobEntity> timerJobEntities)

Specified by:

bulkDeleteTimerJobsWithoutRevisionCheck in interface TimerJobEntityManager

createTimer

protected TimerJobEntity createTimer(JobEntity te)

setNewRepeat

protected void setNewRepeat(JobEntity timerEntity,
 int newRepeatValue)

isValidTime

protected boolean isValidTime(JobEntity timerEntity,
 Date newTimerDate,
 VariableScope variableScope)

calculateNextTimer

protected Date calculateNextTimer(JobEntity timerEntity,
 VariableScope variableScope)

calculateRepeatValue

protected int calculateRepeatValue(JobEntity timerEntity)