public class JobEntityManagerImpl extends AbstractEntityManager<JobEntity> implements JobEntityManager
Modifier and Type | Field and Description |
---|---|
protected JobDataManager |
jobDataManager |
processEngineConfiguration
Constructor and Description |
---|
JobEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration,
JobDataManager jobDataManager) |
create, delete, delete, findById, insert, update, 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
protected JobDataManager jobDataManager
public JobEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration, JobDataManager jobDataManager)
protected DataManager<JobEntity> getDataManager()
getDataManager
in class AbstractEntityManager<JobEntity>
public MessageEntity createMessage()
createMessage
in interface JobEntityManager
public TimerEntity createTimer()
createTimer
in interface JobEntityManager
public TimerEntity createTimer(TimerEntity te)
createTimer
in interface JobEntityManager
public void insert(JobEntity jobEntity, boolean fireCreateEvent)
insert
in interface EntityManager<JobEntity>
insert
in class AbstractEntityManager<JobEntity>
public void send(MessageEntity message)
send
in interface JobEntityManager
public void schedule(TimerEntity timer)
schedule
in interface JobEntityManager
public void retryAsyncJob(JobEntity job)
retryAsyncJob
in interface JobEntityManager
protected void hintAsyncExecutor(JobEntity job)
protected void hintJobExecutor(JobEntity job)
public List<JobEntity> findNextJobsToExecute(Page page)
findNextJobsToExecute
in interface JobEntityManager
public List<JobEntity> findNextTimerJobsToExecute(Page page)
findNextTimerJobsToExecute
in interface JobEntityManager
public List<JobEntity> findAsyncJobsDueToExecute(Page page)
findAsyncJobsDueToExecute
in interface JobEntityManager
public List<JobEntity> findJobsByLockOwner(String lockOwner, int start, int maxNrOfJobs)
findJobsByLockOwner
in interface JobEntityManager
public List<JobEntity> findJobsByExecutionId(String executionId)
findJobsByExecutionId
in interface JobEntityManager
public List<JobEntity> findExclusiveJobsToExecute(String processInstanceId)
findExclusiveJobsToExecute
in interface JobEntityManager
public List<TimerEntity> findUnlockedTimersByDuedate(Date duedate, Page page)
findUnlockedTimersByDuedate
in interface JobEntityManager
public List<TimerEntity> findTimersByExecutionId(String executionId)
findTimersByExecutionId
in interface JobEntityManager
public List<Job> findJobsByQueryCriteria(JobQueryImpl jobQuery, Page page)
findJobsByQueryCriteria
in interface JobEntityManager
public List<Job> findJobsByTypeAndProcessDefinitionIds(String jobHandlerType, List<String> processDefinitionIds)
findJobsByTypeAndProcessDefinitionIds
in interface JobEntityManager
public List<Job> findJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType, String processDefinitionKey)
findJobsByTypeAndProcessDefinitionKeyNoTenantId
in interface JobEntityManager
public List<Job> findJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType, String processDefinitionKey, String tenantId)
findJobsByTypeAndProcessDefinitionKeyAndTenantId
in interface JobEntityManager
public List<Job> findJobsByTypeAndProcessDefinitionId(String jobHandlerType, String processDefinitionId)
findJobsByTypeAndProcessDefinitionId
in interface JobEntityManager
public long findJobCountByQueryCriteria(JobQueryImpl jobQuery)
findJobCountByQueryCriteria
in interface JobEntityManager
public void updateJobTenantIdForDeployment(String deploymentId, String newTenantId)
updateJobTenantIdForDeployment
in interface JobEntityManager
public void delete(JobEntity jobEntity)
delete
in interface EntityManager<JobEntity>
delete
in class AbstractEntityManager<JobEntity>
protected void removeExecutionLink(JobEntity jobEntity)
protected void deleteExceptionByteArrayRef(JobEntity jobEntity)
public void execute(JobEntity jobEntity)
execute
in interface JobEntityManager
protected void executeJobHandler(JobEntity jobEntity)
protected void executeMessageJob(JobEntity jobEntity)
protected void executeTimerJob(TimerEntity timerEntity)
protected void restoreExtraData(TimerEntity timerEntity)
protected int getMaxIterations(org.activiti.bpmn.model.Process process, String activityId)
protected int calculateMaxIterationsValue(String originalExpression)
protected int calculateRepeatValue(TimerEntity timerEntity)
protected void setNewRepeat(TimerEntity timerEntity, int newRepeatValue)
protected boolean isValidTime(TimerEntity timerEntity, Date newTimerDate)
protected Date calculateNextTimer(TimerEntity timerEntity)
public JobDataManager getJobDataManager()
public void setJobDataManager(JobDataManager jobDataManager)
Copyright © 2015 Alfresco. All rights reserved.