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> |
AbstractAsyncJobExecutor.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) |
Runnable |
DefaultExecuteAsyncRunnableFactory.createExecuteAsyncRunnable(JobEntity jobEntity,
CommandExecutor commandExecutor) |
protected Runnable |
DefaultAsyncJobExecutor.createRunnableForJob(JobEntity job) |
protected Runnable |
AbstractAsyncJobExecutor.createRunnableForJob(JobEntity job) |
protected void |
AbstractAsyncJobExecutor.doUnlockJob(JobEntity job) |
boolean |
AsyncExecutor.executeAsyncJob(JobEntity job)
Offers the provided
JobEntity to this AsyncExecutor instance
to execute. |
boolean |
AbstractAsyncJobExecutor.executeAsyncJob(JobEntity job) |
protected void |
DefaultAsyncJobExecutor.unlockJob(JobEntity job,
CommandContext commandContext) |
protected void |
AbstractAsyncJobExecutor.unlockJob(JobEntity job,
CommandContext commandContext) |
Constructor and Description |
---|
ExecuteAsyncRunnable(JobEntity job,
CommandExecutor commandExecutor) |
Modifier and Type | Method and Description |
---|---|
Runnable |
TenantAwareExecuteAsyncRunnableFactory.createExecuteAsyncRunnable(JobEntity jobEntity,
CommandExecutor commandExecutor) |
boolean |
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 |
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) |
Constructor and Description |
---|
ExecuteAsyncJobCmd(JobEntity job) |
ExecuteJobsCmd(JobEntity job) |
LockExclusiveJobCmd(JobEntity job) |
UnlockExclusiveJobCmd(JobEntity job) |
Modifier and Type | Field and Description |
---|---|
protected JobEntity |
SingleJobExecutorContext.currentJob |
protected JobEntity |
MultipleJobsExecutorContext.currentJob |
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 |
TimerExecuteNestedActivityJobHandler.dispatchActivityTimeOut(JobEntity timerEntity,
ActivityImpl activity,
ExecutionEntity execution,
CommandContext commandContext) |
protected void |
TimerExecuteNestedActivityJobHandler.dispatchActivityTimeoutIfNeeded(JobEntity timerEntity,
ExecutionEntity execution,
CommandContext commandContext) |
protected void |
TimerExecuteNestedActivityJobHandler.dispatchExecutionTimeOut(JobEntity timerEntity,
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 |
TimerExecuteNestedActivityJobHandler.execute(JobEntity job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
TimerCatchIntermediateEventJobHandler.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 | Class and Description |
---|---|
class |
MessageEntity |
class |
TimerEntity |
Modifier and Type | Field and Description |
---|---|
protected List<JobEntity> |
ExecutionEntity.jobs |
Modifier and Type | Method and Description |
---|---|
JobEntity |
JobEntityManager.findJobById(String jobId) |
Modifier and Type | Method and Description |
---|---|
List<JobEntity> |
JobEntityManager.findAsyncJobsDueToExecute(Page page) |
List<JobEntity> |
JobEntityManager.findExclusiveJobsToExecute(String processInstanceId) |
List<JobEntity> |
JobEntityManager.findJobsByLockOwner(String lockOwner,
int start,
int maxNrOfJobs) |
List<JobEntity> |
JobEntityManager.findNextJobsToExecute(Page page) |
List<JobEntity> |
JobEntityManager.findNextTimerJobsToExecute(Page page) |
List<JobEntity> |
ExecutionEntity.getJobs() |
protected List<JobEntity> |
ExecutionEntity.getJobsInternal() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionEntity.addJob(JobEntity jobEntity) |
protected void |
JobEntityManager.hintAsyncExecutor(JobEntity job) |
protected void |
JobEntityManager.hintJobExecutor(JobEntity job) |
void |
ExecutionEntity.removeJob(JobEntity job) |
void |
JobEntityManager.retryAsyncJob(JobEntity job)
Deprecated.
|
Copyright © 2016 Alfresco. All rights reserved.