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, updategetAsyncExecutor, 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, getVariableInstanceEntityManagerprotected JobDataManager jobDataManager
public JobEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration, JobDataManager jobDataManager)
protected DataManager<JobEntity> getDataManager()
getDataManager in class AbstractEntityManager<JobEntity>public MessageEntity createMessage()
createMessage in interface JobEntityManagerpublic TimerEntity createTimer()
createTimer in interface JobEntityManagerpublic TimerEntity createTimer(TimerEntity te)
createTimer in interface JobEntityManagerpublic void insert(JobEntity jobEntity, boolean fireCreateEvent)
insert in interface EntityManager<JobEntity>insert in class AbstractEntityManager<JobEntity>public void send(MessageEntity message)
send in interface JobEntityManagerpublic void schedule(TimerEntity timer)
schedule in interface JobEntityManagerpublic void retryAsyncJob(JobEntity job)
retryAsyncJob in interface JobEntityManagerprotected void hintAsyncExecutor(JobEntity job)
protected void hintJobExecutor(JobEntity job)
public List<JobEntity> findNextJobsToExecute(Page page)
findNextJobsToExecute in interface JobEntityManagerpublic List<JobEntity> findNextTimerJobsToExecute(Page page)
findNextTimerJobsToExecute in interface JobEntityManagerpublic List<JobEntity> findAsyncJobsDueToExecute(Page page)
findAsyncJobsDueToExecute in interface JobEntityManagerpublic List<JobEntity> findJobsByLockOwner(String lockOwner, int start, int maxNrOfJobs)
findJobsByLockOwner in interface JobEntityManagerpublic List<JobEntity> findJobsByExecutionId(String executionId)
findJobsByExecutionId in interface JobEntityManagerpublic List<JobEntity> findExclusiveJobsToExecute(String processInstanceId)
findExclusiveJobsToExecute in interface JobEntityManagerpublic List<TimerEntity> findUnlockedTimersByDuedate(Date duedate, Page page)
findUnlockedTimersByDuedate in interface JobEntityManagerpublic List<TimerEntity> findTimersByExecutionId(String executionId)
findTimersByExecutionId in interface JobEntityManagerpublic List<Job> findJobsByQueryCriteria(JobQueryImpl jobQuery, Page page)
findJobsByQueryCriteria in interface JobEntityManagerpublic List<Job> findJobsByTypeAndProcessDefinitionIds(String jobHandlerType, List<String> processDefinitionIds)
findJobsByTypeAndProcessDefinitionIds in interface JobEntityManagerpublic List<Job> findJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType, String processDefinitionKey)
findJobsByTypeAndProcessDefinitionKeyNoTenantId in interface JobEntityManagerpublic List<Job> findJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType, String processDefinitionKey, String tenantId)
findJobsByTypeAndProcessDefinitionKeyAndTenantId in interface JobEntityManagerpublic List<Job> findJobsByTypeAndProcessDefinitionId(String jobHandlerType, String processDefinitionId)
findJobsByTypeAndProcessDefinitionId in interface JobEntityManagerpublic long findJobCountByQueryCriteria(JobQueryImpl jobQuery)
findJobCountByQueryCriteria in interface JobEntityManagerpublic void updateJobTenantIdForDeployment(String deploymentId, String newTenantId)
updateJobTenantIdForDeployment in interface JobEntityManagerpublic 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 JobEntityManagerprotected 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.