| Modifier and Type | Method and Description |
|---|---|
protected void |
DefaultInternalCmmnJobManager.preTimerJobDeleteInternal(JobEntity jobEntity,
VariableScope variableScope) |
| Modifier and Type | Method and Description |
|---|---|
void |
AsyncActivatePlanItemInstanceJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
ExternalWorkerTaskCompleteJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
AsyncInitializePlanModelJobHandler.execute(JobEntity job,
String caseInstanceId,
VariableScope variableScope,
CommandContext commandContext) |
void |
TriggerTimerEventJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
CmmnHistoryCleanupJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
| Modifier and Type | Method and Description |
|---|---|
static JobEntity |
JobUtil.createJob(CaseInstanceEntity caseInstance,
BaseElement baseElement,
String jobHandlerType,
CmmnEngineConfiguration cmmnEngineConfiguration) |
static JobEntity |
JobUtil.createJob(PlanItemInstanceEntity planItemInstance,
BaseElement baseElement,
String jobHandlerType,
CmmnEngineConfiguration cmmnEngineConfiguration) |
protected static JobEntity |
JobUtil.createJob(VariableContainer variableContainer,
BaseElement baseElement,
String jobHandlerType,
CmmnEngineConfiguration cmmnEngineConfiguration) |
| Modifier and Type | Method and Description |
|---|---|
static void |
CmmnLoggingSessionUtil.addAsyncActivityLoggingData(String message,
String type,
JobEntity jobEntity,
PlanItemDefinition planItemDefinition,
PlanItemInstanceEntity planItemInstanceEntity,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
| Modifier and Type | Method and Description |
|---|---|
protected JobEntity |
DefaultFlowable5CompatibilityHandler.convertToActiviti5JobEntity(JobEntity job) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DefaultInternalJobManager.preTimerJobDeleteInternal(JobEntity jobEntity,
VariableScope variableScope) |
| Modifier and Type | Method and Description |
|---|---|
void |
BreakpointJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
ExternalWorkerTaskCompleteJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
ParallelMultiInstanceActivityCompletionJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
AsyncSendEventJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
BpmnHistoryCleanupJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
TimerStartEventJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
AsyncContinuationJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
ProcessInstanceMigrationJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
TimerSuspendProcessDefinitionHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
ProcessEventJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
ParallelMultiInstanceWithNoWaitStatesAsyncLeaveJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
ProcessInstanceMigrationStatusJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
AsyncTriggerJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
TimerActivateProcessDefinitionHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
TriggerTimerEventJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
AsyncCompleteCallActivityJobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
| Modifier and Type | Method and Description |
|---|---|
static JobEntity |
JobUtil.createJob(ExecutionEntity execution,
BaseElement baseElement,
String jobHandlerType,
ProcessEngineConfigurationImpl processEngineConfiguration) |
static JobEntity |
JobUtil.createJob(ExecutionEntity execution,
String jobHandlerType,
ProcessEngineConfigurationImpl processEngineConfiguration) |
| Modifier and Type | Method and Description |
|---|---|
static void |
BpmnLoggingSessionUtil.addAsyncActivityLoggingData(String message,
String type,
JobEntity jobEntity,
FlowElement flowElement,
ExecutionEntity execution) |
| Modifier and Type | Method and Description |
|---|---|
JobEntity |
JobService.createJob() |
JobEntity |
JobService.findJobById(String jobId) |
| Modifier and Type | Method and Description |
|---|---|
List<JobEntity> |
JobService.findJobsByExecutionId(String executionId) |
List<JobEntity> |
JobService.findJobsByProcessInstanceId(String processInstanceId) |
| Modifier and Type | Method and Description |
|---|---|
void |
JobService.createAsyncJob(JobEntity job,
boolean isExclusive) |
void |
JobService.createAsyncJobNoTriggerAsyncExecutor(JobEntity job,
boolean isExclusive) |
void |
JobService.deleteJob(JobEntity job) |
void |
JobHandler.execute(JobEntity job,
String configuration,
VariableScope variableScope,
CommandContext commandContext) |
void |
JobService.insertJob(JobEntity job) |
AbstractRuntimeJobEntity |
TimerJobService.moveJobToTimerJob(JobEntity job) |
void |
ScopeAwareInternalJobManager.preTimerJobDelete(JobEntity jobEntity,
VariableScope variableScope) |
void |
InternalJobManager.preTimerJobDelete(JobEntity jobEntity,
VariableScope variableScope) |
protected abstract void |
ScopeAwareInternalJobManager.preTimerJobDeleteInternal(JobEntity jobEntity,
VariableScope variableScope) |
void |
JobService.scheduleAsyncJob(JobEntity job) |
void |
JobService.updateJob(JobEntity job) |
| Modifier and Type | Method and Description |
|---|---|
JobEntity |
JobServiceImpl.createJob() |
JobEntity |
JobServiceImpl.findJobById(String jobId) |
| Modifier and Type | Method and Description |
|---|---|
List<JobEntity> |
JobServiceImpl.findJobsByExecutionId(String executionId) |
List<JobEntity> |
JobServiceImpl.findJobsByProcessInstanceId(String processInstanceId) |
| Modifier and Type | Method and Description |
|---|---|
void |
JobServiceImpl.createAsyncJob(JobEntity job,
boolean isExclusive) |
void |
JobServiceImpl.createAsyncJobNoTriggerAsyncExecutor(JobEntity job,
boolean isExclusive) |
void |
JobServiceImpl.deleteJob(JobEntity job) |
void |
JobServiceImpl.insertJob(JobEntity job) |
AbstractRuntimeJobEntity |
TimerJobServiceImpl.moveJobToTimerJob(JobEntity job) |
void |
JobServiceImpl.scheduleAsyncJob(JobEntity job) |
void |
JobServiceImpl.updateJob(JobEntity job) |
| Modifier and Type | Method and Description |
|---|---|
JobEntity |
DefaultJobManager.createExecutableJobFromOtherJob(AbstractRuntimeJobEntity job) |
JobEntity |
JobManager.createExecutableJobFromOtherJob(AbstractRuntimeJobEntity job)
Create an executable job from another job
|
protected JobEntity |
DefaultJobManager.createExecutableJobFromOtherJob(AbstractRuntimeJobEntity job,
boolean lockJob) |
JobEntity |
DefaultJobManager.moveExternalWorkerJobToExecutableJob(ExternalWorkerJobEntity externalWorkerJob) |
JobEntity |
JobManager.moveExternalWorkerJobToExecutableJob(ExternalWorkerJobEntity externalWorkerJob)
Moves an
ExternalWorkerJobEntity to become an async JobEntity. |
JobEntity |
DefaultJobManager.moveTimerJobToExecutableJob(TimerJobEntity timerJob) |
JobEntity |
JobManager.moveTimerJobToExecutableJob(TimerJobEntity timerJob)
Moves a
TimerJobEntity to become an async JobEntity. |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultJobManager.createAsyncJob(JobEntity jobEntity,
boolean exclusive) |
void |
JobManager.createAsyncJob(JobEntity jobEntity,
boolean exclusive)
Creates an async job so that it can be continued later in a background thread.
|
protected void |
DefaultJobManager.executeJobHandler(JobEntity jobEntity) |
protected void |
DefaultJobManager.executeMessageJob(JobEntity jobEntity) |
protected void |
DefaultJobManager.executeTimerJob(JobEntity timerEntity) |
protected void |
DefaultJobManager.fillDefaultAsyncJobInfo(JobEntity jobEntity,
boolean exclusive) |
String |
DefaultJobManager.getBusinessCalendarName(JobEntity timerEntity,
VariableScope variableScope) |
String |
JobManager.getBusinessCalendarName(JobEntity timerEntity,
VariableScope variableScope)
Get the business calendar name of the job configuration
|
protected void |
DefaultJobManager.hintAsyncExecutor(JobEntity job) |
protected void |
DefaultJobManager.internalCreateAsyncJob(JobEntity jobEntity,
boolean exclusive) |
protected void |
DefaultJobManager.internalCreateLockedAsyncJob(JobEntity jobEntity,
boolean exclusive) |
protected boolean |
DefaultJobManager.isValidTime(JobEntity timerEntity,
Date newTimerDate,
VariableScope variableScope) |
void |
DefaultJobManager.scheduleAsyncJob(JobEntity jobEntity) |
void |
JobManager.scheduleAsyncJob(JobEntity job)
Schedules and async job.
|
protected void |
DefaultJobManager.triggerExecutorIfNeeded(JobEntity jobEntity) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
AsyncJobMessageHandler.handleJob(JobEntity job)
Handle the job and its data.
|
protected void |
AbstractMessageBasedJobManager.triggerExecutorIfNeeded(JobEntity jobEntity) |
| Modifier and Type | Method and Description |
|---|---|
JobEntity |
MoveTimerToExecutableJobCmd.execute(CommandContext commandContext) |
protected JobEntity |
DeleteJobCmd.getJobToDelete(CommandContext commandContext) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DeleteJobCmd.sendCancelEvent(JobEntity jobToDelete) |
| Modifier and Type | Class and Description |
|---|---|
class |
JobEntityImpl
Job entity.
|
| Modifier and Type | Method and Description |
|---|---|
JobEntity |
JobEntityManagerImpl.findJobByCorrelationId(String correlationId) |
JobEntity |
JobEntityManager.findJobByCorrelationId(String correlationId)
Find the job with the given correlation id
|
| Modifier and Type | Method and Description |
|---|---|
protected Date |
TimerJobEntityManagerImpl.calculateNextTimer(JobEntity timerEntity,
VariableScope variableScope) |
protected int |
TimerJobEntityManagerImpl.calculateRepeatValue(JobEntity timerEntity) |
TimerJobEntity |
TimerJobEntityManagerImpl.createAndCalculateNextTimer(JobEntity timerEntity,
VariableScope variableScope) |
TimerJobEntity |
TimerJobEntityManager.createAndCalculateNextTimer(JobEntity timerEntity,
VariableScope variableScope)
Creates a new
TimerJobEntity, typically when a timer is used in a repeating way. |
protected TimerJobEntity |
TimerJobEntityManagerImpl.createTimer(JobEntity te) |
void |
JobEntityManagerImpl.delete(JobEntity jobEntity) |
void |
JobEntityManagerImpl.delete(JobEntity entity,
boolean fireDeleteEvent) |
protected boolean |
JobEntityManagerImpl.doInsert(JobEntity jobEntity,
boolean fireCreateEvent) |
void |
JobEntityManagerImpl.insert(JobEntity jobEntity,
boolean fireCreateEvent) |
boolean |
JobEntityManagerImpl.insertJobEntity(JobEntity timerJobEntity) |
boolean |
JobEntityManager.insertJobEntity(JobEntity jobEntity)
Insert the
JobEntity, similar to insert(JobEntity), but returns a boolean in case the insert did not go through. |
protected boolean |
TimerJobEntityManagerImpl.isValidTime(JobEntity timerEntity,
Date newTimerDate,
VariableScope variableScope) |
protected void |
TimerJobEntityManagerImpl.setNewRepeat(JobEntity timerEntity,
int newRepeatValue) |
| Modifier and Type | Method and Description |
|---|---|
JobEntity |
JobDataManager.findJobByCorrelationId(String correlationId) |
| Modifier and Type | Field and Description |
|---|---|
protected SingleCachedEntityMatcher<JobEntity> |
MybatisJobDataManager.jobByCorrelationIdMatcher |
protected CachedEntityMatcher<JobEntity> |
MybatisJobDataManager.jobsByExecutionIdMatcher |
| Modifier and Type | Method and Description |
|---|---|
JobEntity |
MybatisJobDataManager.create() |
JobEntity |
MybatisJobDataManager.findJobByCorrelationId(String correlationId) |
| Modifier and Type | Method and Description |
|---|---|
List<JobEntity> |
MybatisJobDataManager.findExpiredJobs(List<String> enabledCategories,
Page page) |
List<JobEntity> |
MybatisJobDataManager.findJobsByExecutionId(String executionId) |
List<JobEntity> |
MybatisJobDataManager.findJobsByProcessInstanceId(String processInstanceId) |
List<JobEntity> |
MybatisJobDataManager.findJobsToExecute(List<String> enabledCategories,
Page page) |
Class<? extends JobEntity> |
MybatisJobDataManager.getManagedEntityClass() |
| Modifier and Type | Method and Description |
|---|---|
void |
MybatisJobDataManager.bulkUpdateJobLockWithoutRevisionCheck(List<JobEntity> jobEntities,
String lockOwner,
Date lockExpirationTime) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
JobsByExecutionIdMatcher.isRetained(JobEntity jobEntity,
Object parameter) |
Copyright © 2023 Flowable. All rights reserved.