Modifier and Type | Method and Description |
---|---|
protected void |
ModificationBatchJobHandler.postProcessJob(ModificationBatchConfiguration configuration,
JobEntity job) |
protected void |
RestartProcessInstancesJobHandler.postProcessJob(RestartProcessInstancesBatchConfiguration configuration,
JobEntity job) |
static boolean |
ProcessEngineLogger.shouldLogJobException(ProcessEngineConfiguration processEngineConfiguration,
JobEntity currentJob) |
Modifier and Type | Method and Description |
---|---|
protected JobEntity |
AbstractBatchJobHandler.createBatchJob(BatchEntity batch,
ByteArrayEntity configuration) |
JobEntity |
BatchEntity.createMonitorJob(boolean setDueDate) |
JobEntity |
BatchEntity.createSeedJob() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractBatchJobHandler.onDelete(BatchJobConfiguration configuration,
JobEntity jobEntity) |
void |
BatchMonitorJobHandler.onDelete(BatchMonitorJobHandler.BatchMonitorJobConfiguration configuration,
JobEntity jobEntity) |
void |
BatchSeedJobHandler.onDelete(BatchSeedJobHandler.BatchSeedJobConfiguration configuration,
JobEntity jobEntity) |
protected void |
AbstractBatchJobHandler.postProcessJob(T configuration,
JobEntity job) |
Modifier and Type | Method and Description |
---|---|
void |
CommandChecker.checkReadJob(JobEntity job)
Checks if it is allowed to read the given job.
|
void |
CommandChecker.checkUpdateJob(JobEntity job)
Checks if it is allowed to update the given job.
|
void |
CommandChecker.checkUpdateRetriesJob(JobEntity job)
Checks if it is allowed to update a job retries.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthorizationCommandChecker.checkReadJob(JobEntity job) |
void |
AuthorizationCommandChecker.checkUpdateJob(JobEntity job) |
void |
AuthorizationCommandChecker.checkUpdateRetriesJob(JobEntity job) |
Modifier and Type | Method and Description |
---|---|
void |
TenantCommandChecker.checkReadJob(JobEntity job) |
void |
TenantCommandChecker.checkUpdateJob(JobEntity job) |
void |
TenantCommandChecker.checkUpdateRetriesJob(JobEntity job) |
Modifier and Type | Method and Description |
---|---|
protected JobEntity |
HistoryCleanupCmd.createJob(int[] minuteChunk) |
protected JobEntity |
JobRetryCmd.getJob() |
protected JobEntity |
UnlockJobCmd.getJob() |
Modifier and Type | Method and Description |
---|---|
protected void |
RecalculateJobDuedateCmd.checkJobType(JobEntity job) |
protected void |
SetJobPriorityCmd.createOpLogEntry(CommandContext commandContext,
long previousPriority,
JobEntity job) |
protected void |
JobRetryCmd.decrementRetries(JobEntity job) |
protected void |
DefaultJobRetryCmd.executeCustomStrategy(CommandContext commandContext,
JobEntity job,
ActivityImpl activity) |
protected TimerDeclarationImpl |
RecalculateJobDuedateCmd.findTimeoutListenerDeclaration(JobEntity job,
ActivityImpl activity) |
protected TimerDeclarationImpl |
RecalculateJobDuedateCmd.findTimerDeclaration(CommandContext commandContext,
JobEntity job) |
protected TimerDeclarationImpl |
RecalculateJobDuedateCmd.findTimerDeclarationForActivity(CommandContext commandContext,
JobEntity job) |
protected TimerDeclarationImpl |
RecalculateJobDuedateCmd.findTimerDeclarationForProcessStartEvent(CommandContext commandContext,
JobEntity job) |
protected ActivityImpl |
DefaultJobRetryCmd.getCurrentActivity(CommandContext commandContext,
JobEntity job) |
protected FailedJobRetryConfiguration |
DefaultJobRetryCmd.getFailedJobRetryConfiguration(JobEntity job,
ActivityImpl activity) |
protected String |
DefaultJobRetryCmd.getFailedJobRetryTimeCycle(JobEntity job,
Expression expression) |
protected void |
DefaultJobRetryCmd.initializeRetries(JobEntity job,
int retries) |
protected boolean |
DefaultJobRetryCmd.isFirstJobExecution(JobEntity job) |
protected void |
JobRetryCmd.logException(JobEntity job) |
protected void |
SetProcessDefinitionVersionCmd.switchVersionOfJob(JobEntity jobEntity,
ProcessDefinitionEntity newProcessDefinition,
Map<String,String> jobDefinitionMapping) |
Modifier and Type | Method and Description |
---|---|
void |
EnginePersistenceLogger.debugJobExecuted(JobEntity jobEntity) |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultHistoryEventProducer.initSequenceCounter(JobEntity job,
HistoryEvent event) |
Modifier and Type | Field and Description |
---|---|
protected JobEntity |
CommandContext.currentJob |
Modifier and Type | Method and Description |
---|---|
JobEntity |
CommandContext.getCurrentJob() |
Modifier and Type | Method and Description |
---|---|
void |
CommandContext.setCurrentJob(JobEntity currentJob) |
Modifier and Type | Class and Description |
---|---|
class |
JobDeclaration<S,T extends JobEntity>
A job declaration is associated with an activity in the process definition graph.
|
Modifier and Type | Field and Description |
---|---|
protected JobEntity |
JobExecutorContext.currentJob
the currently executed job
|
protected JobEntity |
JobFailureCollector.job |
Modifier and Type | Method and Description |
---|---|
JobEntity |
JobExecutorContext.getCurrentJob() |
JobEntity |
JobFailureCollector.getJob() |
Modifier and Type | Method and Description |
---|---|
void |
JobExecutorLogger.exceptionWhileExecutingJob(JobEntity job,
Throwable exception) |
protected void |
FailedJobListener.fireHistoricJobFailedEvt(JobEntity job) |
void |
AsyncContinuationJobHandler.onDelete(AsyncContinuationJobHandler.AsyncContinuationConfiguration configuration,
JobEntity jobEntity) |
void |
ProcessEventJobHandler.onDelete(ProcessEventJobHandler.EventSubscriptionJobConfiguration configuration,
JobEntity jobEntity) |
void |
TimerChangeJobDefinitionSuspensionStateJobHandler.onDelete(TimerChangeJobDefinitionSuspensionStateJobHandler.JobDefinitionSuspensionStateConfiguration configuration,
JobEntity jobEntity) |
void |
TimerChangeProcessDefinitionSuspensionStateJobHandler.onDelete(TimerChangeProcessDefinitionSuspensionStateJobHandler.ProcessDefinitionSuspensionStateConfiguration configuration,
JobEntity jobEntity) |
void |
TimerEventJobHandler.onDelete(TimerEventJobHandler.TimerJobConfiguration configuration,
JobEntity jobEntity) |
void |
JobHandler.onDelete(T configuration,
JobEntity jobEntity)
Clean up before job is deleted.
|
void |
JobExecutorContext.setCurrentJob(JobEntity currentJob) |
void |
JobFailureCollector.setJob(JobEntity job) |
Modifier and Type | Method and Description |
---|---|
protected void |
HistoryCleanupSchedulerCmd.cancelCountEmptyRuns(HistoryCleanupJobHandlerConfiguration configuration,
JobEntity jobEntity) |
protected void |
HistoryCleanupSchedulerCmd.incrementCountEmptyRuns(HistoryCleanupJobHandlerConfiguration configuration,
JobEntity jobEntity) |
void |
HistoryCleanupJobHandler.onDelete(HistoryCleanupJobHandlerConfiguration configuration,
JobEntity jobEntity) |
protected void |
HistoryCleanupSchedulerCmd.rescheduleRegularCall(CommandContext commandContext,
JobEntity jobEntity) |
protected void |
HistoryCleanupSchedulerCmd.suspendJob(JobEntity jobEntity) |
Modifier and Type | Method and Description |
---|---|
protected void |
MigrationBatchJobHandler.postProcessJob(MigrationBatchConfiguration configuration,
JobEntity job) |
Modifier and Type | Field and Description |
---|---|
protected JobEntity |
MigratingJobInstance.jobEntity |
Modifier and Type | Method and Description |
---|---|
JobEntity |
MigratingJobInstance.getJobEntity() |
Modifier and Type | Method and Description |
---|---|
protected ScopeImpl |
MigratingTimerJobInstance.determineTimerTriggerTargetScope(JobEntity jobEntity,
ScopeImpl targetScope) |
Constructor and Description |
---|
MigratingAsyncJobInstance(JobEntity jobEntity,
JobDefinitionEntity jobDefinitionEntity,
ScopeImpl targetScope) |
MigratingJobInstance(JobEntity jobEntity) |
MigratingJobInstance(JobEntity jobEntity,
JobDefinitionEntity jobDefinitionEntity,
ScopeImpl targetScope) |
MigratingTimerJobInstance(JobEntity jobEntity) |
MigratingTimerJobInstance(JobEntity jobEntity,
JobDefinitionEntity jobDefinitionEntity,
ScopeImpl targetScope,
boolean updateEvent,
TimerDeclarationImpl targetTimerDeclaration) |
Modifier and Type | Field and Description |
---|---|
protected MigratingDependentInstanceParseHandler<MigratingActivityInstance,List<JobEntity>> |
MigratingInstanceParser.dependentActivityInstanceJobHandler |
protected MigratingDependentInstanceParseHandler<MigratingTransitionInstance,List<JobEntity>> |
MigratingInstanceParser.dependentTransitionInstanceJobHandler |
protected Collection<JobEntity> |
MigratingInstanceParseContext.jobs |
Modifier and Type | Method and Description |
---|---|
protected List<JobEntity> |
ActivityInstanceHandler.collectActivityInstanceJobs(MigratingActivityInstance migratingInstance) |
protected List<JobEntity> |
MigratingInstanceParser.fetchJobs(CommandContext commandContext,
String processInstanceId) |
MigratingDependentInstanceParseHandler<MigratingActivityInstance,List<JobEntity>> |
MigratingInstanceParser.getDependentActivityInstanceJobHandler() |
MigratingDependentInstanceParseHandler<MigratingTransitionInstance,List<JobEntity>> |
MigratingInstanceParser.getDependentTransitionInstanceJobHandler() |
Modifier and Type | Method and Description |
---|---|
void |
MigratingInstanceParseContext.consume(JobEntity job) |
protected TimerDeclarationImpl |
ActivityInstanceJobHandler.getTargetTimerDeclaration(JobEntity job,
JobHandlerConfiguration jobHandlerConfiguration,
String targetActivity,
Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope,
Map<String,TimerDeclarationImpl> targetTimerDeclarationsInEventScope) |
protected static boolean |
TransitionInstanceJobHandler.isAsyncContinuation(JobEntity job) |
protected static boolean |
ActivityInstanceJobHandler.isNoTimeoutListenerOrMigrates(JobEntity job,
JobHandlerConfiguration jobHandlerConfiguration,
String targetActivity,
Map<String,Map<String,TimerDeclarationImpl>> targetTimeoutListenerDeclarationsInEventScope) |
protected static boolean |
ActivityInstanceJobHandler.isTimerJob(JobEntity job) |
Modifier and Type | Method and Description |
---|---|
void |
ActivityInstanceJobHandler.handle(MigratingInstanceParseContext parseContext,
MigratingActivityInstance activityInstance,
List<JobEntity> elements) |
void |
TransitionInstanceJobHandler.handle(MigratingInstanceParseContext parseContext,
MigratingTransitionInstance transitionInstance,
List<JobEntity> elements) |
void |
MigratingInstanceParseContext.handleDependentActivityInstanceJobs(MigratingActivityInstance migratingInstance,
List<JobEntity> jobs) |
void |
MigratingInstanceParseContext.handleDependentTransitionInstanceJobs(MigratingTransitionInstance migratingInstance,
List<JobEntity> jobs) |
MigratingInstanceParseContext |
MigratingInstanceParseContext.jobs(Collection<JobEntity> jobs) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AsyncProcessStartMigrationValidator.isProcessStartJob(JobEntity job) |
Modifier and Type | Method and Description |
---|---|
UserOperationLogContextEntryBuilder |
UserOperationLogContextEntryBuilder.inContextOf(JobEntity job) |
Modifier and Type | Class and Description |
---|---|
class |
EverLivingJobEntity
JobEntity for ever living job, which can be rescheduled and executed again.
|
class |
MessageEntity
NOTE: instances of Messge Entity should be created via
MessageJobDeclaration . |
class |
TimerEntity |
Modifier and Type | Field and Description |
---|---|
protected List<JobEntity> |
ExecutionEntity.jobs |
Modifier and Type | Method and Description |
---|---|
JobEntity |
JobManager.findJobById(String jobId) |
Modifier and Type | Method and Description |
---|---|
List<JobEntity> |
JobManager.findJobsByConfiguration(String jobHandlerType,
String jobHandlerConfiguration,
String tenantId) |
List<JobEntity> |
JobManager.findJobsByExecutionId(String executionId) |
List<JobEntity> |
JobManager.findJobsByJobDefinitionId(String jobDefinitionId) |
List<JobEntity> |
JobManager.findJobsByProcessInstanceId(String processInstanceId) |
List<JobEntity> |
ExecutionEntity.getJobs() |
protected List<JobEntity> |
ExecutionEntity.getJobsInternal() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionEntity.addJob(JobEntity jobEntity) |
protected boolean |
JobManager.areInSameProcessInstance(JobEntity job1,
JobEntity job2) |
void |
JobManager.deleteJob(JobEntity job) |
void |
JobManager.deleteJob(JobEntity job,
boolean fireDeleteEvent) |
protected void |
JobManager.hintJobExecutor(JobEntity job) |
void |
JobManager.insertAndHintJobExecutor(JobEntity jobEntity) |
void |
JobManager.insertJob(JobEntity job) |
protected boolean |
JobManager.isJobDue(JobEntity job)
Sometimes we get a notification of a job that is not yet due, so we
should not execute it immediately
|
void |
ExecutionEntity.removeJob(JobEntity job) |
void |
JobManager.reschedule(JobEntity jobEntity,
Date newDuedate) |
void |
JobManager.updateJob(JobEntity job) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionEntity.restoreProcessInstance(Collection<ExecutionEntity> executions,
Collection<EventSubscriptionEntity> eventSubscriptions,
Collection<VariableInstanceEntity> variables,
Collection<TaskEntity> tasks,
Collection<JobEntity> jobs,
Collection<IncidentEntity> incidents,
Collection<ExternalTaskEntity> externalTasks)
Restores a complete process instance tree including referenced entities.
|
Copyright © 2021. All rights reserved.