public class MybatisJobDataManager extends AbstractDataManager<JobEntity> implements JobDataManager
Modifier and Type | Field and Description |
---|---|
protected static List<Class<? extends JobEntity>> |
ENTITY_SUBCLASSES |
processEngineConfiguration
Constructor and Description |
---|
MybatisJobDataManager(ProcessEngineConfigurationImpl processEngineConfiguration) |
delete, delete, findById, findById, findByQuery, getDbSqlSession, getEntityCache, getList, insert, update
getAsyncExecutor, getAttachmentEntityManager, getByteArrayEntityManager, getClock, getCommandContext, getCommandExecutor, getCommentEntityManager, getDeploymentEntityManager, getEventDispatcher, getEventSubscriptionEntityManager, getExecutionEntityManager, getGroupEntityManager, getHistoricActivityInstanceEntityManager, getHistoricDetailEntityManager, getHistoricIdentityLinkEntityManager, getHistoricProcessInstanceEntityManager, getHistoricTaskInstanceEntityManager, getHistoricVariableInstanceEntityManager, getHistoryManager, getIdentityInfoEntityManager, getIdentityLinkEntityManager, getJobEntityManager, getJobExecutor, getMembershipEntityManager, getModelEntityManager, getProcessDefinitionEntityManager, getProcessDefinitionInfoEntityManager, getProcessEngineConfiguration, getResourceEntityManager, getSession, getTaskEntityManager, getUserIdentityEntityManager, getVariableInstanceEntityManager
public MybatisJobDataManager(ProcessEngineConfigurationImpl processEngineConfiguration)
public Class<? extends JobEntity> getManagedEntityClass()
getManagedEntityClass
in class AbstractDataManager<JobEntity>
public List<Class<? extends JobEntity>> getManagedEntitySubClasses()
getManagedEntitySubClasses
in class AbstractDataManager<JobEntity>
public MessageEntity createMessage()
createMessage
in interface JobDataManager
public TimerEntity createTimer()
createTimer
in interface JobDataManager
public JobEntity create()
create
in interface DataManager<JobEntity>
public List<JobEntity> findNextJobsToExecute(Page page)
findNextJobsToExecute
in interface JobDataManager
public List<JobEntity> findNextTimerJobsToExecute(Page page)
findNextTimerJobsToExecute
in interface JobDataManager
public List<JobEntity> findAsyncJobsDueToExecute(Page page)
findAsyncJobsDueToExecute
in interface JobDataManager
public List<JobEntity> findJobsByLockOwner(String lockOwner, int start, int maxNrOfJobs)
findJobsByLockOwner
in interface JobDataManager
public List<JobEntity> findJobsByExecutionId(String executionId)
findJobsByExecutionId
in interface JobDataManager
public List<JobEntity> findExclusiveJobsToExecute(String processInstanceId)
findExclusiveJobsToExecute
in interface JobDataManager
public List<TimerEntity> findUnlockedTimersByDuedate(Date duedate, Page page)
findUnlockedTimersByDuedate
in interface JobDataManager
public List<TimerEntity> findTimersByExecutionId(String executionId)
findTimersByExecutionId
in interface JobDataManager
public List<Job> findJobsByQueryCriteria(JobQueryImpl jobQuery, Page page)
findJobsByQueryCriteria
in interface JobDataManager
public List<Job> findJobsByTypeAndProcessDefinitionIds(String jobHandlerType, List<String> processDefinitionIds)
findJobsByTypeAndProcessDefinitionIds
in interface JobDataManager
public List<Job> findJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType, String processDefinitionKey)
findJobsByTypeAndProcessDefinitionKeyNoTenantId
in interface JobDataManager
public List<Job> findJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType, String processDefinitionKey, String tenantId)
findJobsByTypeAndProcessDefinitionKeyAndTenantId
in interface JobDataManager
public List<Job> findJobsByTypeAndProcessDefinitionId(String jobHandlerType, String processDefinitionId)
findJobsByTypeAndProcessDefinitionId
in interface JobDataManager
public long findJobCountByQueryCriteria(JobQueryImpl jobQuery)
findJobCountByQueryCriteria
in interface JobDataManager
public void updateJobTenantIdForDeployment(String deploymentId, String newTenantId)
updateJobTenantIdForDeployment
in interface JobDataManager
Copyright © 2015 Alfresco. All rights reserved.