| 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 | UnlockJobCmd. getJob() | 
| protected JobEntity | JobRetryCmd. 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. currentJobthe 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  | EverLivingJobEntityJobEntity for ever living job, which can be rescheduled and executed again. | 
| class  | MessageEntityNOTE: 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 © 2022. All rights reserved.