Package org.flowable.job.service.impl.persistence.entity

Class ExternalWorkerJobEntityManagerImpl

java.lang.Object

org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager<EntityImpl,DM>

org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager<JobServiceConfiguration,EntityImpl,DM>

org.flowable.job.service.impl.persistence.entity.AbstractJobServiceEngineEntityManager<T,DM>

org.flowable.job.service.impl.persistence.entity.JobInfoEntityManagerImpl<ExternalWorkerJobEntity,ExternalWorkerJobDataManager>

org.flowable.job.service.impl.persistence.entity.ExternalWorkerJobEntityManagerImpl

All Implemented Interfaces:

EntityManager<ExternalWorkerJobEntity>, ExternalWorkerJobEntityManager, JobInfoEntityManager<ExternalWorkerJobEntity>

public class ExternalWorkerJobEntityManagerImpl
extends JobInfoEntityManagerImpl<ExternalWorkerJobEntity,ExternalWorkerJobDataManager>
implements ExternalWorkerJobEntityManager

Author:

Filip Hrisafov

Field Summary

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager

serviceConfiguration

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

dataManager, engineType

Constructor Summary

Constructors

Constructor	Description
ExternalWorkerJobEntityManagerImpl(JobServiceConfiguration jobServiceConfiguration, ExternalWorkerJobDataManager jobDataManager)

Method Summary

Modifier and Type	Method	Description
void	delete(ExternalWorkerJobEntity entity, boolean fireDeleteEvent)
protected boolean	doInsert(ExternalWorkerJobEntity jobEntity, boolean fireCreateEvent)
List<ExternalWorkerJobEntity>	findExternalJobsToExecute(ExternalWorkerJobAcquireBuilderImpl builder, int numberOfJobs)
ExternalWorkerJobEntity	findJobByCorrelationId(String correlationId)	Find the external worker job by the given correlationId
long	findJobCountByQueryCriteria(ExternalWorkerJobQueryImpl jobQuery)	Same as ExternalWorkerJobEntityManager.findJobsByQueryCriteria(ExternalWorkerJobQueryImpl), but only returns a count and not the instances itself.
List<ExternalWorkerJob>	findJobsByQueryCriteria(ExternalWorkerJobQueryImpl jobQuery)	Executes a ExternalWorkerJobQueryImpl and returns the matching ExternalWorkerJobEntity instances.
List<ExternalWorkerJobEntity>	findJobsByScopeIdAndSubScopeId(String scopeId, String subScopeId)	Returns all ExternalWorkerJobEntity for the given scope and subscope.
List<ExternalWorkerJobEntity>	findJobsByWorkerId(String workerId)	Returns all ExternalWorkerJobEntity for the given worker id.
List<ExternalWorkerJobEntity>	findJobsByWorkerIdAndTenantId(String workerId, String tenantId)	Returns all ExternalWorkerJobEntity for the given worker and tenant id.
void	insert(ExternalWorkerJobEntity jobEntity, boolean fireCreateEvent)
boolean	insertExternalWorkerJobEntity(ExternalWorkerJobEntity jobEntity)	Insert the ExternalWorkerJobEntity, similar to insert(ExternalWorkerJobEntity), but returns a boolean in case the insert did not go through.

Methods inherited from class org.flowable.job.service.impl.persistence.entity.JobInfoEntityManagerImpl

bulkUpdateJobLockWithoutRevisionCheck, findExpiredJobs, findJobsByExecutionId, findJobsByProcessInstanceId, findJobsToExecute, resetExpiredJob, updateJobTenantIdForDeployment

Methods inherited from class org.flowable.job.service.impl.persistence.entity.AbstractJobServiceEngineEntityManager

bulkDeleteByteArraysById, createEntityEvent, deleteByteArrayRef

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager

getClock, getEventDispatcher, getServiceConfiguration

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

create, delete, delete, findById, fireEntityDeletedEvent, fireEntityInsertedEvent, fireEntityUpdatedEvent, getDataManager, insert, setDataManager, update, update

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.flowable.common.engine.impl.persistence.entity.EntityManager

create, delete, delete, findById, insert, update, update

Methods inherited from interface org.flowable.job.service.impl.persistence.entity.JobInfoEntityManager

bulkUpdateJobLockWithoutRevisionCheck, findExpiredJobs, findJobsByExecutionId, findJobsByProcessInstanceId, findJobsToExecute, findJobsToExecuteAndLockInBulk, resetExpiredJob, updateJobTenantIdForDeployment

Constructor Details

ExternalWorkerJobEntityManagerImpl

public ExternalWorkerJobEntityManagerImpl(JobServiceConfiguration jobServiceConfiguration,
 ExternalWorkerJobDataManager jobDataManager)

Method Details

insertExternalWorkerJobEntity

public boolean insertExternalWorkerJobEntity(ExternalWorkerJobEntity jobEntity)

Description copied from interface: ExternalWorkerJobEntityManager

Insert the ExternalWorkerJobEntity, similar to insert(ExternalWorkerJobEntity), but returns a boolean in case the insert did not go through. This could happen if the execution related to the ExternalWorkerJobEntity has been removed.

Specified by:

insertExternalWorkerJobEntity in interface ExternalWorkerJobEntityManager

insert

public void insert(ExternalWorkerJobEntity jobEntity,
 boolean fireCreateEvent)

Specified by:

insert in interface EntityManager<ExternalWorkerJobEntity>

Overrides:

insert in class AbstractEntityManager<ExternalWorkerJobEntity,ExternalWorkerJobDataManager>

doInsert

protected boolean doInsert(ExternalWorkerJobEntity jobEntity,
 boolean fireCreateEvent)

findJobByCorrelationId

public ExternalWorkerJobEntity findJobByCorrelationId(String correlationId)

Description copied from interface: ExternalWorkerJobEntityManager

Find the external worker job by the given correlationId

Specified by:

findJobByCorrelationId in interface ExternalWorkerJobEntityManager

findJobsByScopeIdAndSubScopeId

public List<ExternalWorkerJobEntity> findJobsByScopeIdAndSubScopeId(String scopeId,
 String subScopeId)

Description copied from interface: ExternalWorkerJobEntityManager

Returns all ExternalWorkerJobEntity for the given scope and subscope.

Specified by:

findJobsByScopeIdAndSubScopeId in interface ExternalWorkerJobEntityManager

findJobsByWorkerId

public List<ExternalWorkerJobEntity> findJobsByWorkerId(String workerId)

Description copied from interface: ExternalWorkerJobEntityManager

Returns all ExternalWorkerJobEntity for the given worker id.

Specified by:

findJobsByWorkerId in interface ExternalWorkerJobEntityManager

findJobsByWorkerIdAndTenantId

public List<ExternalWorkerJobEntity> findJobsByWorkerIdAndTenantId(String workerId,
 String tenantId)

Description copied from interface: ExternalWorkerJobEntityManager

Returns all ExternalWorkerJobEntity for the given worker and tenant id.

Specified by:

findJobsByWorkerIdAndTenantId in interface ExternalWorkerJobEntityManager

findJobsByQueryCriteria

public List<ExternalWorkerJob> findJobsByQueryCriteria(ExternalWorkerJobQueryImpl jobQuery)

Description copied from interface: ExternalWorkerJobEntityManager

Executes a ExternalWorkerJobQueryImpl and returns the matching ExternalWorkerJobEntity instances.

Specified by:

findJobsByQueryCriteria in interface ExternalWorkerJobEntityManager

Returns:

findJobCountByQueryCriteria

public long findJobCountByQueryCriteria(ExternalWorkerJobQueryImpl jobQuery)

Description copied from interface: ExternalWorkerJobEntityManager

Same as ExternalWorkerJobEntityManager.findJobsByQueryCriteria(ExternalWorkerJobQueryImpl), but only returns a count and not the instances itself.

Specified by:

findJobCountByQueryCriteria in interface ExternalWorkerJobEntityManager

findExternalJobsToExecute

public List<ExternalWorkerJobEntity> findExternalJobsToExecute(ExternalWorkerJobAcquireBuilderImpl builder,
 int numberOfJobs)

Specified by:

findExternalJobsToExecute in interface ExternalWorkerJobEntityManager

delete

public void delete(ExternalWorkerJobEntity entity,
 boolean fireDeleteEvent)

Specified by:

delete in interface EntityManager<ExternalWorkerJobEntity>

Overrides:

delete in class AbstractEntityManager<ExternalWorkerJobEntity,ExternalWorkerJobDataManager>