| Modifier and Type | Method and Description |
|---|---|
List<Job> |
TimerJobQueryImpl.executeList(CommandContext commandContext,
Page page) |
List<Job> |
JobQueryImpl.executeList(CommandContext commandContext,
Page page) |
| Modifier and Type | Field and Description |
|---|---|
protected Job |
AsyncJobAddedNotification.job |
| Modifier and Type | Method and Description |
|---|---|
protected void |
TimerExecuteNestedActivityJobHandler.dispatchActivityTimeOut(Job job,
ActivityImpl activity,
ExecutionEntity execution,
CommandContext commandContext) |
protected void |
TimerExecuteNestedActivityJobHandler.dispatchActivityTimeoutIfNeeded(Job timerEntity,
ExecutionEntity execution,
CommandContext commandContext) |
protected void |
TimerExecuteNestedActivityJobHandler.dispatchExecutionTimeOut(Job job,
ExecutionEntity execution,
CommandContext commandContext) |
protected void |
TimerStartEventJobHandler.dispatchTimerFiredEvent(Job job,
CommandContext commandContext) |
void |
TimerSuspendProcessDefinitionHandler.execute(Job job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
AsyncContinuationJobHandler.execute(Job job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
TimerStartEventJobHandler.execute(Job job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
TimerExecuteNestedActivityJobHandler.execute(Job job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
TimerCatchIntermediateEventJobHandler.execute(Job job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
ProcessEventJobHandler.execute(Job job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
TimerActivateProcessDefinitionHandler.execute(Job job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
void |
JobHandler.execute(Job job,
String configuration,
ExecutionEntity execution,
CommandContext commandContext) |
protected void |
TimerStartEventJobHandler.startProcessDefinitionByKey(Job job,
String configuration,
DeploymentManager deploymentManager,
CommandContext commandContext) |
protected void |
TimerStartEventJobHandler.startProcessInstanceWithInitialActivity(Job job,
String configuration,
DeploymentManager deploymentManager,
CommandContext commandContext) |
| Constructor and Description |
|---|
AsyncJobAddedNotification(Job job,
AsyncExecutor asyncExecutor) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractJobEntity
Abstract job entity class.
|
class |
DeadLetterJobEntity |
class |
JobEntity
Job entity for persisting executable jobs.
|
class |
SuspendedJobEntity |
class |
TimerJobEntity |
| Modifier and Type | Method and Description |
|---|---|
List<Job> |
DeadLetterJobEntityManager.findDeadLetterJobsByTypeAndProcessDefinitionId(String jobHandlerType,
String processDefinitionId) |
List<Job> |
DeadLetterJobEntityManager.findDeadLetterJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType,
String processDefinitionKey,
String tenantId) |
List<Job> |
DeadLetterJobEntityManager.findDeadLetterJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType,
String processDefinitionKey) |
List<Job> |
DeadLetterJobEntityManager.findJobsByQueryCriteria(JobQueryImpl jobQuery,
Page page) |
List<Job> |
SuspendedJobEntityManager.findJobsByQueryCriteria(JobQueryImpl jobQuery,
Page page) |
List<Job> |
JobEntityManager.findJobsByQueryCriteria(JobQueryImpl jobQuery,
Page page) |
List<Job> |
JobEntityManager.findJobsByTypeAndProcessDefinitionId(String jobHandlerType,
String processDefinitionId) |
List<Job> |
JobEntityManager.findJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType,
String processDefinitionKey,
String tenantId) |
List<Job> |
JobEntityManager.findJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType,
String processDefinitionKey) |
List<Job> |
SuspendedJobEntityManager.findSuspendedJobsByTypeAndProcessDefinitionId(String jobHandlerType,
String processDefinitionId) |
List<Job> |
SuspendedJobEntityManager.findSuspendedJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType,
String processDefinitionKey,
String tenantId) |
List<Job> |
SuspendedJobEntityManager.findSuspendedJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType,
String processDefinitionKey) |
List<Job> |
TimerJobEntityManager.findTimerJobsByQueryCriteria(TimerJobQueryImpl jobQuery,
Page page) |
List<Job> |
TimerJobEntityManager.findTimerJobsByTypeAndProcessDefinitionId(String jobHandlerType,
String processDefinitionId) |
List<Job> |
TimerJobEntityManager.findTimerJobsByTypeAndProcessDefinitionKeyAndTenantId(String jobHandlerType,
String processDefinitionKey,
String tenantId) |
List<Job> |
TimerJobEntityManager.findTimerJobsByTypeAndProcessDefinitionKeyNoTenantId(String jobHandlerType,
String processDefinitionKey) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
JobEntityManager.hintAsyncExecutor(Job job) |
| Modifier and Type | Method and Description |
|---|---|
Job |
CmmnManagementService.moveDeadLetterJobToExecutableJob(String jobId,
int retries)
Moves a job that is in the dead letter job table back to be an executable job,
and resetting the retries (as the retries were probably 0 when it was put into the dead letter job table).
|
Job |
CmmnManagementService.moveJobToDeadLetterJob(String jobId)
Moves a job to the dead letter job table (eg.
|
Job |
CmmnManagementService.moveSuspendedJobToExecutableJob(String jobId)
Moves a suspended job from the suspended letter job table back to be an executable job.
|
Job |
CmmnManagementService.moveTimerToExecutableJob(String jobId)
Moves a timer job to the executable job table (eg.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
DefaultCmmnJobParentStateResolver.isSuspended(Job job) |
| Modifier and Type | Method and Description |
|---|---|
Job |
CmmnManagementServiceImpl.moveDeadLetterJobToExecutableJob(String jobId,
int retries) |
Job |
CmmnManagementServiceImpl.moveJobToDeadLetterJob(String jobId) |
Job |
CmmnManagementServiceImpl.moveSuspendedJobToExecutableJob(String jobId) |
Job |
CmmnManagementServiceImpl.moveTimerToExecutableJob(String jobId) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DefaultInternalCmmnJobManager.clearJobScopeLockInternal(Job job) |
protected void |
DefaultInternalCmmnJobManager.handleJobDeleteInternal(Job job) |
protected boolean |
DefaultInternalCmmnJobManager.handleJobInsertInternal(Job job) |
protected void |
DefaultInternalCmmnJobManager.lockJobScopeInternal(Job job) |
protected VariableScope |
DefaultInternalCmmnJobManager.resolveVariableScopeInternal(Job job) |
| Modifier and Type | Method and Description |
|---|---|
void |
CmmnRestApiInterceptor.accessJobInfoById(Job job) |
JobResponse |
CmmnRestResponseFactory.createJobResponse(Job job) |
JobResponse |
CmmnRestResponseFactory.createJobResponse(Job job,
RestUrlBuilder urlBuilder) |
void |
CmmnRestApiInterceptor.deleteJob(Job job) |
| Modifier and Type | Method and Description |
|---|---|
List<JobResponse> |
CmmnRestResponseFactory.createJobResponseList(List<Job> jobs) |
| Modifier and Type | Method and Description |
|---|---|
protected Job |
JobBaseResource.getDeadLetterJobById(String jobId) |
protected Job |
JobBaseResource.getJobById(String jobId) |
protected Job |
JobBaseResource.getSuspendedJobById(String jobId) |
protected Job |
JobBaseResource.getTimerJobById(String jobId) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
JobBaseResource.validateJob(Job job,
String jobId) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultFlowable5CompatibilityHandler.executeJob(Job job) |
void |
DefaultFlowable5CompatibilityHandler.executeJobWithLockAndRetry(Job job) |
void |
DefaultFlowable5CompatibilityHandler.handleFailedJob(Job job,
Throwable exception) |
| Modifier and Type | Method and Description |
|---|---|
Job |
ManagementService.findJobByCorrelationId(String jobCorrelationId)
Find a job by a correlation id.
|
Job |
ManagementService.moveDeadLetterJobToExecutableJob(String jobId,
int retries)
Moves a job that is in the dead letter job table back to be an executable job,
and resetting the retries (as the retries was 0 when it was put into the dead letter job table).
|
Job |
ManagementService.moveJobToDeadLetterJob(String jobId)
Moves a job to the dead letter job table (eg.
|
Job |
ManagementService.moveSuspendedJobToExecutableJob(String jobId)
Moves a suspended job from the suspended letter job table back to be an executable job.
|
Job |
ManagementService.moveTimerToExecutableJob(String jobId)
Moves a timer job to the executable job table (eg.
|
Job |
ManagementService.rescheduleTimeCycleJob(String jobId,
String timeCycle)
Reschedule a timer job with a time cycle.
|
Job |
ManagementService.rescheduleTimeDateJob(String jobId,
String timeDate)
Reschedule a timer job with a time date.
|
Job |
ManagementService.rescheduleTimeDurationJob(String jobId,
String timeDuration)
Reschedule a timer job with a time duration.
|
Job |
ManagementService.rescheduleTimerJob(String jobId,
String timeDate,
String timeDuration,
String timeCycle,
String endDate,
String calendarName)
Reschedule a timer job.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Flowable5CompatibilityHandler.executeJob(Job job) |
void |
Flowable5CompatibilityHandler.executeJobWithLockAndRetry(Job job) |
void |
Flowable5CompatibilityHandler.handleFailedJob(Job job,
Throwable exception) |
| Modifier and Type | Method and Description |
|---|---|
static FlowableJobRescheduledEvent |
FlowableEventBuilder.createJobRescheduledEvent(FlowableEngineEventType type,
Job newJob,
String originalJobId) |
| Constructor and Description |
|---|
FlowableJobRescheduledEventImpl(Job entity,
String rescheduledJobId,
FlowableEngineEventType type) |
| Modifier and Type | Method and Description |
|---|---|
Job |
ManagementServiceImpl.findJobByCorrelationId(String jobCorrelationId) |
Job |
ManagementServiceImpl.moveDeadLetterJobToExecutableJob(String jobId,
int retries) |
Job |
ManagementServiceImpl.moveJobToDeadLetterJob(String jobId) |
Job |
ManagementServiceImpl.moveSuspendedJobToExecutableJob(String jobId) |
Job |
ManagementServiceImpl.moveTimerToExecutableJob(String jobId) |
Job |
ManagementServiceImpl.rescheduleTimeCycleJob(String jobId,
String timeCycle) |
Job |
ManagementServiceImpl.rescheduleTimeDateJob(String jobId,
String timeDate) |
Job |
ManagementServiceImpl.rescheduleTimeDurationJob(String jobId,
String timeDuration) |
Job |
ManagementServiceImpl.rescheduleTimerJob(String jobId,
String timeDate,
String timeDuration,
String timeCycle,
String endDate,
String calendarName) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
DefaultProcessJobParentStateResolver.isSuspended(Job job) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DefaultInternalJobManager.clearJobScopeLockInternal(Job job) |
void |
DefaultInternalJobCompatibilityManager.executeV5Job(Job job) |
void |
DefaultInternalJobCompatibilityManager.executeV5JobWithLockAndRetry(Job job) |
protected void |
DefaultInternalJobManager.handleJobDeleteInternal(Job job) |
protected boolean |
DefaultInternalJobManager.handleJobInsertInternal(Job job) |
boolean |
DefaultInternalJobCompatibilityManager.isFlowable5Job(Job job) |
protected void |
DefaultInternalJobManager.lockJobScopeInternal(Job job) |
protected VariableScope |
DefaultInternalJobManager.resolveVariableScopeInternal(Job job) |
| Modifier and Type | Method and Description |
|---|---|
protected String |
AbstractFlowableTestCase.getJobActivityId(Job job) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
AcquiredExternalWorkerJob |
interface |
ExternalWorkerJob |
| Modifier and Type | Method and Description |
|---|---|
void |
ScopeAwareInternalJobManager.clearJobScopeLock(Job job) |
void |
InternalJobManager.clearJobScopeLock(Job job) |
protected abstract void |
ScopeAwareInternalJobManager.clearJobScopeLockInternal(Job job) |
void |
InternalJobCompatibilityManager.executeV5Job(Job job) |
void |
InternalJobCompatibilityManager.executeV5JobWithLockAndRetry(Job job) |
protected InternalJobManager |
ScopeAwareInternalJobManager.findInternalJobManager(Job job) |
void |
ScopeAwareInternalJobManager.handleJobDelete(Job job) |
void |
InternalJobManager.handleJobDelete(Job job) |
protected abstract void |
ScopeAwareInternalJobManager.handleJobDeleteInternal(Job job) |
boolean |
ScopeAwareInternalJobManager.handleJobInsert(Job job) |
boolean |
InternalJobManager.handleJobInsert(Job job) |
protected abstract boolean |
ScopeAwareInternalJobManager.handleJobInsertInternal(Job job) |
boolean |
InternalJobCompatibilityManager.isFlowable5Job(Job job) |
boolean |
InternalJobParentStateResolver.isSuspended(Job job) |
void |
ScopeAwareInternalJobManager.lockJobScope(Job job) |
void |
InternalJobManager.lockJobScope(Job job) |
protected abstract void |
ScopeAwareInternalJobManager.lockJobScopeInternal(Job job) |
VariableScope |
ScopeAwareInternalJobManager.resolveVariableScope(Job job) |
VariableScope |
InternalJobManager.resolveVariableScope(Job job) |
protected abstract VariableScope |
ScopeAwareInternalJobManager.resolveVariableScopeInternal(Job job) |
| Modifier and Type | Class and Description |
|---|---|
class |
AcquiredExternalWorkerJobImpl |
| Modifier and Type | Method and Description |
|---|---|
List<Job> |
TimerJobQueryImpl.executeList(CommandContext commandContext) |
List<Job> |
SuspendedJobQueryImpl.executeList(CommandContext commandContext) |
List<Job> |
DeadLetterJobQueryImpl.executeList(CommandContext commandContext) |
List<Job> |
JobQueryImpl.executeList(CommandContext commandContext) |
| Modifier and Type | Field and Description |
|---|---|
protected Job |
FailedJobListener.job |
| Modifier and Type | Method and Description |
|---|---|
Job |
DefaultJobManager.moveDeadLetterJobToExecutableJob(DeadLetterJobEntity deadLetterJobEntity,
int retries) |
Job |
JobManager.moveDeadLetterJobToExecutableJob(DeadLetterJobEntity deadLetterJobEntity,
int retries)
Transforms a
DeadLetterJobEntity to a Job, thus making it executable again. |
| Constructor and Description |
|---|
FailedJobListener(CommandExecutor commandExecutor,
Job job,
JobServiceConfiguration jobServiceConfiguration) |
| Modifier and Type | Field and Description |
|---|---|
protected Job |
UnlockExclusiveJobCmd.job |
protected Job |
LockExclusiveJobCmd.job |
| Modifier and Type | Method and Description |
|---|---|
Job |
MoveSuspendedJobToExecutableJobCmd.execute(CommandContext commandContext) |
Job |
GetJobByCorrelationIdCmd.execute(CommandContext commandContext) |
Job |
MoveDeadLetterJobToExecutableJobCmd.execute(CommandContext commandContext) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
UnacquireOwnedJobsCmd.logJobUnlocking(Job job) |
| Constructor and Description |
|---|
LockExclusiveJobCmd(Job job,
JobServiceConfiguration jobServiceConfiguration) |
UnlockExclusiveJobCmd(Job job,
JobServiceConfiguration jobServiceConfiguration) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
AbstractRuntimeJobEntity |
interface |
DeadLetterJobEntity
Suspended jobs are stored separately to increase the normal job query performance
|
interface |
ExternalWorkerJobEntity
Represents an external job.
|
interface |
JobEntity
Represents an async job: a piece of logic that needs to be executed asynchronously.
|
interface |
SuspendedJobEntity
Suspended jobs are stored separately to increase the normal job query performance
|
interface |
TimerJobEntity
Stub of the common parts of a timer job.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractJobEntityImpl
Abstract job entity class.
|
class |
DeadLetterJobEntityImpl
DeadLetterJob entity, necessary for persistence.
|
class |
ExternalWorkerJobEntityImpl |
class |
JobEntityImpl
Job entity.
|
class |
SuspendedJobEntityImpl
TimerJob entity, necessary for persistence.
|
class |
TimerJobEntityImpl
TimerJob entity, necessary for persistence.
|
| Modifier and Type | Method and Description |
|---|---|
List<Job> |
DeadLetterJobEntityManagerImpl.findJobsByQueryCriteria(DeadLetterJobQueryImpl jobQuery) |
List<Job> |
DeadLetterJobEntityManager.findJobsByQueryCriteria(DeadLetterJobQueryImpl jobQuery)
Executes a
JobQueryImpl and returns the matching DeadLetterJobEntity instances. |
List<Job> |
JobEntityManagerImpl.findJobsByQueryCriteria(JobQueryImpl jobQuery) |
List<Job> |
JobEntityManager.findJobsByQueryCriteria(JobQueryImpl jobQuery)
Executes a
JobQueryImpl and returns the matching JobEntity instances. |
List<Job> |
SuspendedJobEntityManagerImpl.findJobsByQueryCriteria(SuspendedJobQueryImpl jobQuery) |
List<Job> |
SuspendedJobEntityManager.findJobsByQueryCriteria(SuspendedJobQueryImpl jobQuery)
Executes a
JobQueryImpl and returns the matching SuspendedJobEntity instances. |
List<Job> |
TimerJobEntityManagerImpl.findJobsByQueryCriteria(TimerJobQueryImpl jobQuery) |
List<Job> |
TimerJobEntityManager.findJobsByQueryCriteria(TimerJobQueryImpl jobQuery)
Executes a
JobQueryImpl and returns the matching TimerJobEntity instances. |
| Modifier and Type | Method and Description |
|---|---|
List<Job> |
DeadLetterJobDataManager.findJobsByQueryCriteria(DeadLetterJobQueryImpl jobQuery) |
List<Job> |
JobDataManager.findJobsByQueryCriteria(JobQueryImpl jobQuery) |
List<Job> |
SuspendedJobDataManager.findJobsByQueryCriteria(SuspendedJobQueryImpl jobQuery) |
List<Job> |
TimerJobDataManager.findJobsByQueryCriteria(TimerJobQueryImpl jobQuery) |
| Modifier and Type | Method and Description |
|---|---|
List<Job> |
MybatisDeadLetterJobDataManager.findJobsByQueryCriteria(DeadLetterJobQueryImpl jobQuery) |
List<Job> |
MybatisJobDataManager.findJobsByQueryCriteria(JobQueryImpl jobQuery) |
List<Job> |
MybatisSuspendedJobDataManager.findJobsByQueryCriteria(SuspendedJobQueryImpl jobQuery) |
List<Job> |
MybatisTimerJobDataManager.findJobsByQueryCriteria(TimerJobQueryImpl jobQuery) |
| Modifier and Type | Method and Description |
|---|---|
void |
BpmnRestApiInterceptor.accessJobInfoById(Job job) |
JobResponse |
RestResponseFactory.createDeadLetterJobResponse(Job job) |
JobResponse |
RestResponseFactory.createJobResponse(Job job) |
JobResponse |
RestResponseFactory.createJobResponse(Job job,
RestUrlBuilder urlBuilder) |
protected JobResponse |
RestResponseFactory.createJobResponse(Job job,
RestUrlBuilder urlBuilder,
String[] urlJobSegments) |
JobResponse |
RestResponseFactory.createSuspendedJobResponse(Job job) |
JobResponse |
RestResponseFactory.createTimerJobResponse(Job job) |
void |
BpmnRestApiInterceptor.deleteJob(Job job) |
| Modifier and Type | Method and Description |
|---|---|
List<JobResponse> |
RestResponseFactory.createDeadLetterJobResponseList(List<Job> jobs) |
List<JobResponse> |
RestResponseFactory.createJobResponseList(List<Job> jobs) |
protected List<JobResponse> |
RestResponseFactory.createJobResponseList(List<Job> jobs,
String[] urlJobSegments) |
List<JobResponse> |
RestResponseFactory.createSuspendedJobResponseList(List<Job> jobs) |
List<JobResponse> |
RestResponseFactory.createTimerJobResponseList(List<Job> jobs) |
| Modifier and Type | Method and Description |
|---|---|
protected Job |
JobBaseResource.getDeadLetterJobById(String jobId) |
protected Job |
JobBaseResource.getJobById(String jobId) |
protected Job |
JobBaseResource.getSuspendedJobById(String jobId) |
protected Job |
JobBaseResource.getTimerJobById(String jobId) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
JobBaseResource.validateJob(Job job,
String jobId) |
Copyright © 2023 Flowable. All rights reserved.