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

Class DeadLetterJobEntityManagerImpl

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<DeadLetterJobEntity,DeadLetterJobDataManager>

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

All Implemented Interfaces:

EntityManager<DeadLetterJobEntity>, DeadLetterJobEntityManager

public class DeadLetterJobEntityManagerImpl
extends AbstractJobServiceEngineEntityManager<DeadLetterJobEntity,DeadLetterJobDataManager>
implements DeadLetterJobEntityManager

Author:

Tijs Rademakers

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
DeadLetterJobEntityManagerImpl(JobServiceConfiguration jobServiceConfiguration, DeadLetterJobDataManager jobDataManager)

Method Summary

Modifier and Type	Method	Description
protected DeadLetterJobEntity	createDeadLetterJob(AbstractRuntimeJobEntity job)
void	delete(DeadLetterJobEntity jobEntity)
DeadLetterJobEntity	findJobByCorrelationId(String correlationId)	Find the deadletter job with the given correlation id.
long	findJobCountByQueryCriteria(DeadLetterJobQueryImpl jobQuery)	Same as DeadLetterJobEntityManager.findJobsByQueryCriteria(DeadLetterJobQueryImpl), but only returns a count and not the instances itself.
List<DeadLetterJobEntity>	findJobsByExecutionId(String id)	Returns all DeadLetterJobEntity instances related to an execution id.
List<DeadLetterJobEntity>	findJobsByProcessInstanceId(String id)	Returns all DeadLetterJobEntity instances related to a process instance
List<Job>	findJobsByQueryCriteria(DeadLetterJobQueryImpl jobQuery)	Executes a JobQueryImpl and returns the matching DeadLetterJobEntity instances.
void	insert(DeadLetterJobEntity jobEntity)
void	insert(DeadLetterJobEntity jobEntity, boolean fireCreateEvent)
void	updateJobTenantIdForDeployment(String deploymentId, String newTenantId)	Changes the tenantId for all jobs related to a given deployment id.

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, 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, update, update

Constructor Details

DeadLetterJobEntityManagerImpl

public DeadLetterJobEntityManagerImpl(JobServiceConfiguration jobServiceConfiguration,
 DeadLetterJobDataManager jobDataManager)

Method Details

findJobByCorrelationId

public DeadLetterJobEntity findJobByCorrelationId(String correlationId)

Description copied from interface: DeadLetterJobEntityManager

Find the deadletter job with the given correlation id.

Specified by:

findJobByCorrelationId in interface DeadLetterJobEntityManager

findJobsByExecutionId

public List<DeadLetterJobEntity> findJobsByExecutionId(String id)

Description copied from interface: DeadLetterJobEntityManager

Returns all DeadLetterJobEntity instances related to an execution id.

Specified by:

findJobsByExecutionId in interface DeadLetterJobEntityManager

findJobsByProcessInstanceId

public List<DeadLetterJobEntity> findJobsByProcessInstanceId(String id)

Description copied from interface: DeadLetterJobEntityManager

Returns all DeadLetterJobEntity instances related to a process instance

Specified by:

findJobsByProcessInstanceId in interface DeadLetterJobEntityManager

findJobsByQueryCriteria

public List<Job> findJobsByQueryCriteria(DeadLetterJobQueryImpl jobQuery)

Description copied from interface: DeadLetterJobEntityManager

Executes a JobQueryImpl and returns the matching DeadLetterJobEntity instances.

Specified by:

findJobsByQueryCriteria in interface DeadLetterJobEntityManager

findJobCountByQueryCriteria

public long findJobCountByQueryCriteria(DeadLetterJobQueryImpl jobQuery)

Description copied from interface: DeadLetterJobEntityManager

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

Specified by:

findJobCountByQueryCriteria in interface DeadLetterJobEntityManager

updateJobTenantIdForDeployment

public void updateJobTenantIdForDeployment(String deploymentId,
 String newTenantId)

Description copied from interface: DeadLetterJobEntityManager

Changes the tenantId for all jobs related to a given deployment id.

Specified by:

updateJobTenantIdForDeployment in interface DeadLetterJobEntityManager

insert

public void insert(DeadLetterJobEntity jobEntity,
 boolean fireCreateEvent)

Specified by:

insert in interface EntityManager<DeadLetterJobEntity>

Overrides:

insert in class AbstractEntityManager<DeadLetterJobEntity,DeadLetterJobDataManager>

insert

public void insert(DeadLetterJobEntity jobEntity)

Specified by:

insert in interface EntityManager<DeadLetterJobEntity>

Overrides:

insert in class AbstractEntityManager<DeadLetterJobEntity,DeadLetterJobDataManager>

delete

public void delete(DeadLetterJobEntity jobEntity)

Specified by:

delete in interface EntityManager<DeadLetterJobEntity>

Overrides:

delete in class AbstractEntityManager<DeadLetterJobEntity,DeadLetterJobDataManager>

createDeadLetterJob

protected DeadLetterJobEntity createDeadLetterJob(AbstractRuntimeJobEntity job)