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

Class MybatisDeadLetterJobDataManager

java.lang.Object

org.flowable.common.engine.impl.db.AbstractDataManager<DeadLetterJobEntity>

org.flowable.job.service.impl.persistence.entity.data.impl.MybatisDeadLetterJobDataManager

All Implemented Interfaces:

DataManager<DeadLetterJobEntity>, DeadLetterJobDataManager

public class MybatisDeadLetterJobDataManager
extends AbstractDataManager<DeadLetterJobEntity>
implements DeadLetterJobDataManager

Author:

Tijs Rademakers

Field Summary

Fields

Modifier and Type	Field	Description
protected SingleCachedEntityMatcher<DeadLetterJobEntity>	deadLetterByCorrelationIdMatcher
protected CachedEntityMatcher<DeadLetterJobEntity>	deadLetterByExecutionIdMatcher
protected JobServiceConfiguration	jobServiceConfiguration

Fields inherited from class org.flowable.common.engine.impl.db.AbstractDataManager

MAX_ENTRIES_IN_CLAUSE

Constructor Summary

Constructors

Constructor	Description
MybatisDeadLetterJobDataManager(JobServiceConfiguration jobServiceConfiguration)

Method Summary

Modifier and Type	Method	Description
DeadLetterJobEntity	create()
DeadLetterJobEntity	findJobByCorrelationId(String correlationId)
long	findJobCountByQueryCriteria(DeadLetterJobQueryImpl jobQuery)
List<DeadLetterJobEntity>	findJobsByExecutionId(String executionId)
List<DeadLetterJobEntity>	findJobsByProcessInstanceId(String processInstanceId)
List<Job>	findJobsByQueryCriteria(DeadLetterJobQueryImpl jobQuery)
protected IdGenerator	getIdGenerator()
Class<? extends DeadLetterJobEntity>	getManagedEntityClass()
void	updateJobTenantIdForDeployment(String deploymentId, String newTenantId)

Methods inherited from class org.flowable.common.engine.impl.db.AbstractDataManager

bulkDelete, bulkDeleteEntities, bulkUpdateEntities, createSafeInValuesList, delete, delete, deleteCachedEntities, deleteCachedEntities, executeChangeWithInClause, findById, findByQuery, getCommandContext, getDbSqlSession, getEntity, getEntityCache, getList, getList, getList, getList, getList, getListFromCache, getListFromCache, getManagedEntitySubClasses, getSession, insert, isEntityInserted, 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.data.DataManager

delete, delete, findById, insert, update

Field Details

deadLetterByExecutionIdMatcher

protected CachedEntityMatcher<DeadLetterJobEntity> deadLetterByExecutionIdMatcher

deadLetterByCorrelationIdMatcher

protected SingleCachedEntityMatcher<DeadLetterJobEntity> deadLetterByCorrelationIdMatcher

jobServiceConfiguration

protected JobServiceConfiguration jobServiceConfiguration

Constructor Details

MybatisDeadLetterJobDataManager

public MybatisDeadLetterJobDataManager(JobServiceConfiguration jobServiceConfiguration)

Method Details

getManagedEntityClass

public Class<? extends DeadLetterJobEntity> getManagedEntityClass()

Specified by:

getManagedEntityClass in class AbstractDataManager<DeadLetterJobEntity>

create

public DeadLetterJobEntity create()

Specified by:

create in interface DataManager<DeadLetterJobEntity>

findJobByCorrelationId

public DeadLetterJobEntity findJobByCorrelationId(String correlationId)

Specified by:

findJobByCorrelationId in interface DeadLetterJobDataManager

findJobsByQueryCriteria

public List<Job> findJobsByQueryCriteria(DeadLetterJobQueryImpl jobQuery)

Specified by:

findJobsByQueryCriteria in interface DeadLetterJobDataManager

findJobCountByQueryCriteria

public long findJobCountByQueryCriteria(DeadLetterJobQueryImpl jobQuery)

Specified by:

findJobCountByQueryCriteria in interface DeadLetterJobDataManager

findJobsByExecutionId

public List<DeadLetterJobEntity> findJobsByExecutionId(String executionId)

Specified by:

findJobsByExecutionId in interface DeadLetterJobDataManager

findJobsByProcessInstanceId

public List<DeadLetterJobEntity> findJobsByProcessInstanceId(String processInstanceId)

Specified by:

findJobsByProcessInstanceId in interface DeadLetterJobDataManager

updateJobTenantIdForDeployment

public void updateJobTenantIdForDeployment(String deploymentId,
 String newTenantId)

Specified by:

updateJobTenantIdForDeployment in interface DeadLetterJobDataManager

getIdGenerator

protected IdGenerator getIdGenerator()

Specified by:

getIdGenerator in class AbstractDataManager<DeadLetterJobEntity>