ExternalWorkerJobDataManager (Flowable Open Source 7.1.0.18)

All Superinterfaces:: DataManager<ExternalWorkerJobEntity>, JobInfoDataManager<ExternalWorkerJobEntity>

All Known Implementing Classes:: MybatisExternalWorkerJobDataManager

public interface ExternalWorkerJobDataManager extends DataManager<ExternalWorkerJobEntity>, JobInfoDataManager<ExternalWorkerJobEntity>

Author:: Filip Hrisafov

Method Summary

Modifier and Type

Method

Description

void

deleteJobsByExecutionId(String executionId)

List<ExternalWorkerJobEntity>

findExternalJobsToExecute(ExternalWorkerJobAcquireBuilderImpl builder, int numberOfJobs)

ExternalWorkerJobEntity

findJobByCorrelationId(String correlationId)

long

findJobCountByQueryCriteria(ExternalWorkerJobQueryImpl jobQuery)

List<ExternalWorkerJob>

findJobsByQueryCriteria(ExternalWorkerJobQueryImpl jobQuery)

List<ExternalWorkerJobEntity>

findJobsByScopeIdAndSubScopeId(String scopeId, String subScopeId)

List<ExternalWorkerJobEntity>

findJobsByWorkerId(String workerId)

List<ExternalWorkerJobEntity>

findJobsByWorkerIdAndTenantId(String workerId, String tenantId)

Methods inherited from interface org.flowable.common.engine.impl.persistence.entity.data.DataManager
create, delete, delete, findById, insert, update

Methods inherited from interface org.flowable.job.service.impl.persistence.entity.data.JobInfoDataManager
bulkUpdateJobLockWithoutRevisionCheck, findExpiredJobs, findJobsByExecutionId, findJobsByProcessInstanceId, findJobsToExecute, resetExpiredJob, updateJobTenantIdForDeployment

Method Details
- findJobByCorrelationId
  
  ExternalWorkerJobEntity findJobByCorrelationId(String correlationId)
- findJobsByQueryCriteria
  
  List<ExternalWorkerJob> findJobsByQueryCriteria(ExternalWorkerJobQueryImpl jobQuery)
- findJobCountByQueryCriteria
  
  long findJobCountByQueryCriteria(ExternalWorkerJobQueryImpl jobQuery)
- deleteJobsByExecutionId
  
  void deleteJobsByExecutionId(String executionId)
- findExternalJobsToExecute
  
  List<ExternalWorkerJobEntity> findExternalJobsToExecute(ExternalWorkerJobAcquireBuilderImpl builder, int numberOfJobs)
- findJobsByScopeIdAndSubScopeId
  
  List<ExternalWorkerJobEntity> findJobsByScopeIdAndSubScopeId(String scopeId, String subScopeId)
- findJobsByWorkerId
  
  List<ExternalWorkerJobEntity> findJobsByWorkerId(String workerId)
- findJobsByWorkerIdAndTenantId
  
  List<ExternalWorkerJobEntity> findJobsByWorkerIdAndTenantId(String workerId, String tenantId)