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

Class EventSubscriptionEntityManagerImpl

java.lang.Object

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

org.flowable.common.engine.impl.persistence.entity.AbstractServiceEngineEntityManager<EventSubscriptionServiceConfiguration,EventSubscriptionEntity,EventSubscriptionDataManager>

org.flowable.eventsubscription.service.impl.persistence.entity.EventSubscriptionEntityManagerImpl

All Implemented Interfaces:

EntityManager<EventSubscriptionEntity>, EventSubscriptionEntityManager

public class EventSubscriptionEntityManagerImpl
extends AbstractServiceEngineEntityManager<EventSubscriptionServiceConfiguration,EventSubscriptionEntity,EventSubscriptionDataManager>
implements EventSubscriptionEntityManager

Author:

Joram Barrez, 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
EventSubscriptionEntityManagerImpl(EventSubscriptionServiceConfiguration eventSubscriptionServiceConfiguration, EventSubscriptionDataManager eventSubscriptionDataManager)

Method Summary

Modifier and Type	Method	Description
CompensateEventSubscriptionEntity	createCompensateEventSubscription()
EventSubscription	createEventSubscription(EventSubscriptionBuilder eventSubscriptionBuilder)
GenericEventSubscriptionEntity	createGenericEventSubscription()
MessageEventSubscriptionEntity	createMessageEventSubscription()
SignalEventSubscriptionEntity	createSignalEventSubscription()
void	deleteEventSubscriptionsByExecutionId(String executionId)
void	deleteEventSubscriptionsForProcessDefinition(String processDefinitionId)
void	deleteEventSubscriptionsForProcessDefinitionAndProcessStartEvent(String processDefinitionId, String eventType, String activityId, String configuration)
void	deleteEventSubscriptionsForScopeDefinitionAndScopeStartEvent(String scopeDefinitionId, String eventType, String configuration)
void	deleteEventSubscriptionsForScopeDefinitionIdAndType(String scopeDefinitionId, String scopeType)
void	deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId(String scopeDefinitionId, String scopeType)
void	deleteEventSubscriptionsForScopeIdAndType(String scopeId, String scopeType)
List<CompensateEventSubscriptionEntity>	findCompensateEventSubscriptionsByExecutionId(String executionId)
List<CompensateEventSubscriptionEntity>	findCompensateEventSubscriptionsByExecutionIdAndActivityId(String executionId, String activityId)
List<CompensateEventSubscriptionEntity>	findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId(String processInstanceId, String activityId)
long	findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)
List<EventSubscriptionEntity>	findEventSubscriptionsByExecution(String executionId)
List<EventSubscriptionEntity>	findEventSubscriptionsByExecutionAndType(String executionId, String type)
List<EventSubscriptionEntity>	findEventSubscriptionsByName(String type, String eventName, String tenantId)
List<EventSubscriptionEntity>	findEventSubscriptionsByNameAndExecution(String type, String eventName, String executionId)
List<EventSubscriptionEntity>	findEventSubscriptionsByProcessInstanceAndActivityId(String processInstanceId, String activityId, String type)
List<EventSubscriptionEntity>	findEventSubscriptionsByProcessInstanceAndType(String processInstanceId, String type)
List<EventSubscription>	findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)
List<EventSubscriptionEntity>	findEventSubscriptionsByScopeIdAndType(String scopeId, String type)
List<EventSubscriptionEntity>	findEventSubscriptionsBySubScopeId(String subScopeId)
List<EventSubscriptionEntity>	findEventSubscriptionsByTypeAndProcessDefinitionId(String type, String processDefinitionId, String tenantId)
List<MessageEventSubscriptionEntity>	findMessageEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
MessageEventSubscriptionEntity	findMessageStartEventSubscriptionByName(String messageName, String tenantId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByEventName(String eventName, String tenantId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByNameAndExecution(String name, String executionId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByScopeAndEventName(String scopeId, String scopeType, String eventName)
protected CompensateEventSubscriptionEntity	insertCompensationEvent(EventSubscriptionBuilder eventSubscriptionBuilder)
protected GenericEventSubscriptionEntity	insertGenericEvent(EventSubscriptionBuilder eventSubscriptionBuilder)
protected MessageEventSubscriptionEntity	insertMessageEvent(EventSubscriptionBuilder eventSubscriptionBuilder)
protected SignalEventSubscriptionEntity	insertSignalEvent(EventSubscriptionBuilder eventSubscriptionBuilder)
boolean	lockEventSubscription(String eventSubscriptionId)
protected List<MessageEventSubscriptionEntity>	toMessageEventSubscriptionEntityList(List<EventSubscriptionEntity> result)
protected List<SignalEventSubscriptionEntity>	toSignalEventSubscriptionEntityList(List<EventSubscriptionEntity> result)
void	unlockEventSubscription(String eventSubscriptionId)
void	updateEventSubscriptionProcessDefinitionId(String oldProcessDefinitionId, String newProcessDefinitionId, String eventType, String activityId, String scopeDefinitionKey, String configuration)
void	updateEventSubscriptionScopeDefinitionId(String oldScopeDefinitionId, String newScopeDefinitionId, String eventType, String scopeDefinitionKey, String configuration)
void	updateEventSubscriptionTenantId(String oldTenantId, String newTenantId)

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, createEntityEvent, delete, delete, delete, findById, fireEntityDeletedEvent, fireEntityInsertedEvent, fireEntityUpdatedEvent, getDataManager, insert, 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, delete, findById, insert, insert, update, update

Constructor Details

EventSubscriptionEntityManagerImpl

public EventSubscriptionEntityManagerImpl(EventSubscriptionServiceConfiguration eventSubscriptionServiceConfiguration,
 EventSubscriptionDataManager eventSubscriptionDataManager)

Method Details

createCompensateEventSubscription

public CompensateEventSubscriptionEntity createCompensateEventSubscription()

Specified by:

createCompensateEventSubscription in interface EventSubscriptionEntityManager

createMessageEventSubscription

public MessageEventSubscriptionEntity createMessageEventSubscription()

Specified by:

createMessageEventSubscription in interface EventSubscriptionEntityManager

createSignalEventSubscription

public SignalEventSubscriptionEntity createSignalEventSubscription()

Specified by:

createSignalEventSubscription in interface EventSubscriptionEntityManager

createGenericEventSubscription

public GenericEventSubscriptionEntity createGenericEventSubscription()

Specified by:

createGenericEventSubscription in interface EventSubscriptionEntityManager

createEventSubscription

public EventSubscription createEventSubscription(EventSubscriptionBuilder eventSubscriptionBuilder)

Specified by:

createEventSubscription in interface EventSubscriptionEntityManager

findCompensateEventSubscriptionsByExecutionId

public List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByExecutionId(String executionId)

Specified by:

findCompensateEventSubscriptionsByExecutionId in interface EventSubscriptionEntityManager

findCompensateEventSubscriptionsByExecutionIdAndActivityId

public List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByExecutionIdAndActivityId(String executionId,
 String activityId)

Specified by:

findCompensateEventSubscriptionsByExecutionIdAndActivityId in interface EventSubscriptionEntityManager

findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId

public List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId(String processInstanceId,
 String activityId)

Specified by:

findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId in interface EventSubscriptionEntityManager

findEventSubscriptionCountByQueryCriteria

public long findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)

Specified by:

findEventSubscriptionCountByQueryCriteria in interface EventSubscriptionEntityManager

findEventSubscriptionsByQueryCriteria

public List<EventSubscription> findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)

Specified by:

findEventSubscriptionsByQueryCriteria in interface EventSubscriptionEntityManager

findMessageEventSubscriptionsByProcessInstanceAndEventName

public List<MessageEventSubscriptionEntity> findMessageEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId,
 String eventName)

Specified by:

findMessageEventSubscriptionsByProcessInstanceAndEventName in interface EventSubscriptionEntityManager

findSignalEventSubscriptionsByEventName

public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByEventName(String eventName,
 String tenantId)

Specified by:

findSignalEventSubscriptionsByEventName in interface EventSubscriptionEntityManager

findSignalEventSubscriptionsByProcessInstanceAndEventName

public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId,
 String eventName)

Specified by:

findSignalEventSubscriptionsByProcessInstanceAndEventName in interface EventSubscriptionEntityManager

findSignalEventSubscriptionsByScopeAndEventName

public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByScopeAndEventName(String scopeId,
 String scopeType,
 String eventName)

Specified by:

findSignalEventSubscriptionsByScopeAndEventName in interface EventSubscriptionEntityManager

findSignalEventSubscriptionsByNameAndExecution

public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByNameAndExecution(String name,
 String executionId)

Specified by:

findSignalEventSubscriptionsByNameAndExecution in interface EventSubscriptionEntityManager

findEventSubscriptionsByExecutionAndType

public List<EventSubscriptionEntity> findEventSubscriptionsByExecutionAndType(String executionId,
 String type)

Specified by:

findEventSubscriptionsByExecutionAndType in interface EventSubscriptionEntityManager

findEventSubscriptionsByProcessInstanceAndType

public List<EventSubscriptionEntity> findEventSubscriptionsByProcessInstanceAndType(String processInstanceId,
 String type)

Specified by:

findEventSubscriptionsByProcessInstanceAndType in interface EventSubscriptionEntityManager

findEventSubscriptionsByProcessInstanceAndActivityId

public List<EventSubscriptionEntity> findEventSubscriptionsByProcessInstanceAndActivityId(String processInstanceId,
 String activityId,
 String type)

Specified by:

findEventSubscriptionsByProcessInstanceAndActivityId in interface EventSubscriptionEntityManager

findEventSubscriptionsByExecution

public List<EventSubscriptionEntity> findEventSubscriptionsByExecution(String executionId)

Specified by:

findEventSubscriptionsByExecution in interface EventSubscriptionEntityManager

findEventSubscriptionsBySubScopeId

public List<EventSubscriptionEntity> findEventSubscriptionsBySubScopeId(String subScopeId)

Specified by:

findEventSubscriptionsBySubScopeId in interface EventSubscriptionEntityManager

findEventSubscriptionsByTypeAndProcessDefinitionId

public List<EventSubscriptionEntity> findEventSubscriptionsByTypeAndProcessDefinitionId(String type,
 String processDefinitionId,
 String tenantId)

Specified by:

findEventSubscriptionsByTypeAndProcessDefinitionId in interface EventSubscriptionEntityManager

findEventSubscriptionsByScopeIdAndType

public List<EventSubscriptionEntity> findEventSubscriptionsByScopeIdAndType(String scopeId,
 String type)

Specified by:

findEventSubscriptionsByScopeIdAndType in interface EventSubscriptionEntityManager

findEventSubscriptionsByName

public List<EventSubscriptionEntity> findEventSubscriptionsByName(String type,
 String eventName,
 String tenantId)

Specified by:

findEventSubscriptionsByName in interface EventSubscriptionEntityManager

findEventSubscriptionsByNameAndExecution

public List<EventSubscriptionEntity> findEventSubscriptionsByNameAndExecution(String type,
 String eventName,
 String executionId)

Specified by:

findEventSubscriptionsByNameAndExecution in interface EventSubscriptionEntityManager

findMessageStartEventSubscriptionByName

public MessageEventSubscriptionEntity findMessageStartEventSubscriptionByName(String messageName,
 String tenantId)

Specified by:

findMessageStartEventSubscriptionByName in interface EventSubscriptionEntityManager

updateEventSubscriptionTenantId

public void updateEventSubscriptionTenantId(String oldTenantId,
 String newTenantId)

Specified by:

updateEventSubscriptionTenantId in interface EventSubscriptionEntityManager

updateEventSubscriptionProcessDefinitionId

public void updateEventSubscriptionProcessDefinitionId(String oldProcessDefinitionId,
 String newProcessDefinitionId,
 String eventType,
 String activityId,
 String scopeDefinitionKey,
 String configuration)

Specified by:

updateEventSubscriptionProcessDefinitionId in interface EventSubscriptionEntityManager

updateEventSubscriptionScopeDefinitionId

public void updateEventSubscriptionScopeDefinitionId(String oldScopeDefinitionId,
 String newScopeDefinitionId,
 String eventType,
 String scopeDefinitionKey,
 String configuration)

Specified by:

updateEventSubscriptionScopeDefinitionId in interface EventSubscriptionEntityManager

lockEventSubscription

public boolean lockEventSubscription(String eventSubscriptionId)

Specified by:

lockEventSubscription in interface EventSubscriptionEntityManager

unlockEventSubscription

public void unlockEventSubscription(String eventSubscriptionId)

Specified by:

unlockEventSubscription in interface EventSubscriptionEntityManager

deleteEventSubscriptionsForProcessDefinition

public void deleteEventSubscriptionsForProcessDefinition(String processDefinitionId)

Specified by:

deleteEventSubscriptionsForProcessDefinition in interface EventSubscriptionEntityManager

deleteEventSubscriptionsByExecutionId

public void deleteEventSubscriptionsByExecutionId(String executionId)

Specified by:

deleteEventSubscriptionsByExecutionId in interface EventSubscriptionEntityManager

deleteEventSubscriptionsForScopeIdAndType

public void deleteEventSubscriptionsForScopeIdAndType(String scopeId,
 String scopeType)

Specified by:

deleteEventSubscriptionsForScopeIdAndType in interface EventSubscriptionEntityManager

deleteEventSubscriptionsForScopeDefinitionIdAndType

public void deleteEventSubscriptionsForScopeDefinitionIdAndType(String scopeDefinitionId,
 String scopeType)

Specified by:

deleteEventSubscriptionsForScopeDefinitionIdAndType in interface EventSubscriptionEntityManager

deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId

public void deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId(String scopeDefinitionId,
 String scopeType)

Specified by:

deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId in interface EventSubscriptionEntityManager

deleteEventSubscriptionsForProcessDefinitionAndProcessStartEvent

public void deleteEventSubscriptionsForProcessDefinitionAndProcessStartEvent(String processDefinitionId,
 String eventType,
 String activityId,
 String configuration)

Specified by:

deleteEventSubscriptionsForProcessDefinitionAndProcessStartEvent in interface EventSubscriptionEntityManager

deleteEventSubscriptionsForScopeDefinitionAndScopeStartEvent

public void deleteEventSubscriptionsForScopeDefinitionAndScopeStartEvent(String scopeDefinitionId,
 String eventType,
 String configuration)

Specified by:

deleteEventSubscriptionsForScopeDefinitionAndScopeStartEvent in interface EventSubscriptionEntityManager

insertSignalEvent

protected SignalEventSubscriptionEntity insertSignalEvent(EventSubscriptionBuilder eventSubscriptionBuilder)

insertMessageEvent

protected MessageEventSubscriptionEntity insertMessageEvent(EventSubscriptionBuilder eventSubscriptionBuilder)

insertCompensationEvent

protected CompensateEventSubscriptionEntity insertCompensationEvent(EventSubscriptionBuilder eventSubscriptionBuilder)

insertGenericEvent

protected GenericEventSubscriptionEntity insertGenericEvent(EventSubscriptionBuilder eventSubscriptionBuilder)

toSignalEventSubscriptionEntityList

protected List<SignalEventSubscriptionEntity> toSignalEventSubscriptionEntityList(List<EventSubscriptionEntity> result)

toMessageEventSubscriptionEntityList

protected List<MessageEventSubscriptionEntity> toMessageEventSubscriptionEntityList(List<EventSubscriptionEntity> result)