Modifier and Type | Method and Description |
---|---|
void |
Activiti5CompatibilityHandler.executeJobWithLockAndRetry(JobEntity job) |
void |
Activiti5CompatibilityHandler.handleFailedJob(JobEntity job,
Throwable exception) |
Modifier and Type | Field and Description |
---|---|
protected JobEntity |
ExecuteAsyncRunnable.job |
Modifier and Type | Field and Description |
---|---|
protected Map<String,JobEntity> |
AcquiredJobEntities.acquiredJobs |
protected LinkedList<JobEntity> |
DefaultAsyncJobExecutor.temporaryJobQueue |
Modifier and Type | Method and Description |
---|---|
Collection<JobEntity> |
AcquiredJobEntities.getJobs() |
Modifier and Type | Method and Description |
---|---|
void |
AcquiredJobEntities.addJob(JobEntity job) |
Runnable |
ExecuteAsyncRunnableFactory.createExecuteAsyncRunnable(JobEntity jobEntity,
CommandExecutor commandExecutor) |
void |
DefaultAsyncJobExecutor.executeAsyncJob(JobEntity job) |
void |
AsyncExecutor.executeAsyncJob(JobEntity job) |
Constructor and Description |
---|
ExecuteAsyncRunnable(JobEntity job,
CommandExecutor commandExecutor) |
Modifier and Type | Method and Description |
---|---|
Runnable |
TenantAwareExecuteAsyncRunnableFactory.createExecuteAsyncRunnable(JobEntity jobEntity,
CommandExecutor commandExecutor) |
void |
ExecutorPerTenantAsyncExecutor.executeAsyncJob(JobEntity job) |
Constructor and Description |
---|
TenantAwareExecuteAsyncRunnable(JobEntity job,
CommandExecutor commandExecutor,
TenantInfoHolder tenantInfoHolder,
String tenantId) |
Modifier and Type | Field and Description |
---|---|
protected JobEntity |
UnlockExclusiveJobCmd.job |
protected JobEntity |
LockExclusiveJobCmd.job |
protected JobEntity |
ExecuteJobsCmd.job |
protected JobEntity |
ExecuteAsyncJobCmd.job |
protected JobEntity |
ExecuteJobsCmd.ManualJobExecutionCommandContextCloseListener.jobEntity |
Modifier and Type | Method and Description |
---|---|
protected JobEntity |
DeleteJobCmd.getJobToDelete(CommandContext commandContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
AcquireAsyncJobsDueCmd.lockJob(CommandContext commandContext,
JobEntity job,
int lockTimeInMillis) |
protected void |
AcquireTimerJobsCmd.lockJob(CommandContext commandContext,
JobEntity job,
String lockOwner,
int lockTimeInMillis) |
protected void |
AcquireJobsCmd.lockJob(CommandContext commandContext,
JobEntity job,
String lockOwner,
int lockTimeInMillis) |
protected void |
DeleteJobCmd.sendCancelEvent(JobEntity jobToDelete) |
Constructor and Description |
---|
ExecuteAsyncJobCmd(JobEntity job) |
ExecuteJobsCmd(JobEntity job) |
LockExclusiveJobCmd(JobEntity job) |
ManualJobExecutionCommandContextCloseListener(JobEntity jobEntity) |
UnlockExclusiveJobCmd(JobEntity job) |
Modifier and Type | Field and Description |
---|---|
protected JobEntity |
SingleJobExecutorContext.currentJob |
protected JobEntity |
MultipleJobsExecutorContext.currentJob |
protected JobEntity |
ExecuteJobsRunnable.job |
protected JobEntity |
AsyncJobAddedNotification.job |
Modifier and Type | Field and Description |
---|---|
protected List<JobEntity> |
SingleJobExecutorContext.currentProcessorJobQueue |
Modifier and Type | Method and Description |
---|---|
JobEntity |
SingleJobExecutorContext.getCurrentJob() |
JobEntity |
MultipleJobsExecutorContext.getCurrentJob() |
JobEntity |
JobExecutorContext.getCurrentJob() |
Modifier and Type | Method and Description |
---|---|
List<JobEntity> |
SingleJobExecutorContext.getCurrentProcessorJobQueue() |
Modifier and Type | Method and Description |
---|---|
protected void |
TriggerTimerEventJobHandler.dispatchActivityTimeOut(JobEntity timerEntity,
org.activiti.bpmn.model.FlowNode flowNode,
ExecutionEntity execution,
CommandContext commandContext) |
protected void |
TriggerTimerEventJobHandler.dispatchExecutionTimeOut(JobEntity timerEntity,
ExecutionEntity execution,
List<String> processedElements,
CommandContext commandContext) |
void |
TriggerTimerEventJobHandler.execute(JobEntity job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
TimerSuspendProcessDefinitionHandler.execute(JobEntity job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
TimerStartEventJobHandler.execute(JobEntity job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
TimerActivateProcessDefinitionHandler.execute(JobEntity job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
ProcessEventJobHandler.execute(JobEntity job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
JobHandler.execute(JobEntity job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
AsyncContinuationJobHandler.execute(JobEntity job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
JobExecutor.jobDone(JobEntity job) |
void |
SingleJobExecutorContext.setCurrentJob(JobEntity currentJob) |
void |
MultipleJobsExecutorContext.setCurrentJob(JobEntity currentJob) |
void |
JobExecutorContext.setCurrentJob(JobEntity currentJob) |
Constructor and Description |
---|
AsyncJobAddedNotification(JobEntity job,
AsyncExecutor asyncExecutor) |
ExecuteJobsRunnable(JobExecutor jobExecutor,
JobEntity job) |
Modifier and Type | Interface and Description |
---|---|
interface |
MessageEntity |
interface |
TimerEntity |
Modifier and Type | Class and Description |
---|---|
class |
JobEntityImpl
Stub of the common parts of a Job.
|
class |
MessageEntityImpl |
class |
TimerEntityImpl |
Modifier and Type | Field and Description |
---|---|
protected List<JobEntity> |
ExecutionEntityImpl.jobs |
Modifier and Type | Method and Description |
---|---|
List<JobEntity> |
JobEntityManagerImpl.findAsyncJobsDueToExecute(Page page) |
List<JobEntity> |
JobEntityManager.findAsyncJobsDueToExecute(Page page) |
List<JobEntity> |
JobEntityManagerImpl.findExclusiveJobsToExecute(String processInstanceId) |
List<JobEntity> |
JobEntityManager.findExclusiveJobsToExecute(String processInstanceId) |
List<JobEntity> |
JobEntityManagerImpl.findJobsByExecutionId(String executionId) |
List<JobEntity> |
JobEntityManager.findJobsByExecutionId(String executionId) |
List<JobEntity> |
JobEntityManagerImpl.findJobsByLockOwner(String lockOwner,
int start,
int maxNrOfJobs) |
List<JobEntity> |
JobEntityManager.findJobsByLockOwner(String lockOwner,
int start,
int maxNrOfJobs) |
List<JobEntity> |
JobEntityManagerImpl.findNextJobsToExecute(Page page) |
List<JobEntity> |
JobEntityManager.findNextJobsToExecute(Page page) |
List<JobEntity> |
JobEntityManagerImpl.findNextTimerJobsToExecute(Page page) |
List<JobEntity> |
JobEntityManager.findNextTimerJobsToExecute(Page page) |
protected DataManager<JobEntity> |
JobEntityManagerImpl.getDataManager() |
List<JobEntity> |
ExecutionEntityImpl.getJobs() |
List<JobEntity> |
ExecutionEntity.getJobs() |
Modifier and Type | Method and Description |
---|---|
void |
JobEntityManagerImpl.delete(JobEntity jobEntity) |
protected void |
JobEntityManagerImpl.deleteExceptionByteArrayRef(JobEntity jobEntity)
Deletes a the byte array used to store the exception information.
|
void |
JobEntityManagerImpl.execute(JobEntity jobEntity) |
void |
JobEntityManager.execute(JobEntity jobEntity) |
protected void |
JobEntityManagerImpl.executeJobHandler(JobEntity jobEntity) |
protected void |
JobEntityManagerImpl.executeMessageJob(JobEntity jobEntity) |
protected void |
JobEntityManagerImpl.hintAsyncExecutor(JobEntity job) |
protected void |
JobEntityManagerImpl.hintJobExecutor(JobEntity job) |
void |
JobEntityManagerImpl.insert(JobEntity jobEntity,
boolean fireCreateEvent) |
protected void |
JobEntityManagerImpl.removeExecutionLink(JobEntity jobEntity)
Removes the job's execution's reference to this job, iff the job has an associated execution.
|
void |
JobEntityManagerImpl.retryAsyncJob(JobEntity job) |
void |
JobEntityManager.retryAsyncJob(JobEntity job) |
Modifier and Type | Method and Description |
---|---|
List<JobEntity> |
JobDataManager.findAsyncJobsDueToExecute(Page page) |
List<JobEntity> |
JobDataManager.findExclusiveJobsToExecute(String processInstanceId) |
List<JobEntity> |
JobDataManager.findJobsByExecutionId(String executionId) |
List<JobEntity> |
JobDataManager.findJobsByLockOwner(String lockOwner,
int start,
int maxNrOfJobs) |
List<JobEntity> |
JobDataManager.findNextJobsToExecute(Page page) |
List<JobEntity> |
JobDataManager.findNextTimerJobsToExecute(Page page) |
Modifier and Type | Field and Description |
---|---|
protected static List<Class<? extends JobEntity>> |
MybatisJobDataManager.ENTITY_SUBCLASSES |
Modifier and Type | Method and Description |
---|---|
JobEntity |
MybatisJobDataManager.create() |
Modifier and Type | Method and Description |
---|---|
List<JobEntity> |
MybatisJobDataManager.findAsyncJobsDueToExecute(Page page) |
List<JobEntity> |
MybatisJobDataManager.findExclusiveJobsToExecute(String processInstanceId) |
List<JobEntity> |
MybatisJobDataManager.findJobsByExecutionId(String executionId) |
List<JobEntity> |
MybatisJobDataManager.findJobsByLockOwner(String lockOwner,
int start,
int maxNrOfJobs) |
List<JobEntity> |
MybatisJobDataManager.findNextJobsToExecute(Page page) |
List<JobEntity> |
MybatisJobDataManager.findNextTimerJobsToExecute(Page page) |
Class<? extends JobEntity> |
MybatisJobDataManager.getManagedEntityClass() |
List<Class<? extends JobEntity>> |
MybatisJobDataManager.getManagedEntitySubClasses() |
Copyright © 2015 Alfresco. All rights reserved.