Package org.flowable.eventsubscription.service.impl

Class EventSubscriptionServiceImpl

java.lang.Object

org.flowable.common.engine.impl.service.CommonServiceImpl<EventSubscriptionServiceConfiguration>

org.flowable.eventsubscription.service.impl.EventSubscriptionServiceImpl

All Implemented Interfaces:

EventSubscriptionService

public class EventSubscriptionServiceImpl
extends CommonServiceImpl<EventSubscriptionServiceConfiguration>
implements EventSubscriptionService

Author:

Tijs Rademakers

Field Summary

Fields inherited from class org.flowable.common.engine.impl.service.CommonServiceImpl

configuration

Constructor Summary

Constructors

Constructor	Description
EventSubscriptionServiceImpl(EventSubscriptionServiceConfiguration eventSubscriptionServiceConfiguration)

Method Summary

Modifier and Type	Method	Description
EventSubscription	createEventSubscription(EventSubscriptionBuilder builder)
EventSubscriptionBuilder	createEventSubscriptionBuilder()
MessageEventSubscriptionEntity	createMessageEventSubscription()
SignalEventSubscriptionEntity	createSignalEventSubscription()
void	deleteEventSubscription(EventSubscriptionEntity eventSubscription)
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)
EventSubscriptionEntity	findById(String eventSubscriptionId)
List<CompensateEventSubscriptionEntity>	findCompensateEventSubscriptionsByExecutionId(String executionId)
List<CompensateEventSubscriptionEntity>	findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId(String processInstanceId, String activityId)
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<EventSubscription>	findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQuery)
List<EventSubscriptionEntity>	findEventSubscriptionsBySubScopeId(String subScopeId)
List<EventSubscriptionEntity>	findEventSubscriptionsByTypeAndProcessDefinitionId(String type, String processDefinitionId, String tenantId)
List<MessageEventSubscriptionEntity>	findMessageEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
MessageEventSubscriptionEntity	findMessageStartEventSubscriptionByName(String eventName, String tenantId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByEventName(String eventName, String tenantId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByNameAndExecution(String eventName, String executionId)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
List<SignalEventSubscriptionEntity>	findSignalEventSubscriptionsByScopeAndEventName(String scopeId, String scopeType, String eventName)
EventSubscriptionEntityManager	getEventSubscriptionEntityManager()
void	insertEventSubscription(EventSubscriptionEntity eventSubscription)
boolean	lockEventSubscription(String eventSubscriptionId)
void	unlockEventSubscription(String eventSubscriptionId)
void	updateEventSubscription(EventSubscriptionEntity eventSubscription)
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.service.CommonServiceImpl

getConfiguration

Methods inherited from class java.lang.Object

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

Constructor Details

EventSubscriptionServiceImpl

public EventSubscriptionServiceImpl(EventSubscriptionServiceConfiguration eventSubscriptionServiceConfiguration)

Method Details

findById

public EventSubscriptionEntity findById(String eventSubscriptionId)

Specified by:

findById in interface EventSubscriptionService

findEventSubscriptionsByName

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

Specified by:

findEventSubscriptionsByName in interface EventSubscriptionService

findEventSubscriptionsByExecution

public List<EventSubscriptionEntity> findEventSubscriptionsByExecution(String executionId)

Specified by:

findEventSubscriptionsByExecution in interface EventSubscriptionService

findEventSubscriptionsByNameAndExecution

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

Specified by:

findEventSubscriptionsByNameAndExecution in interface EventSubscriptionService

findEventSubscriptionsBySubScopeId

public List<EventSubscriptionEntity> findEventSubscriptionsBySubScopeId(String subScopeId)

Specified by:

findEventSubscriptionsBySubScopeId in interface EventSubscriptionService

findEventSubscriptionsByProcessInstanceAndActivityId

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

Specified by:

findEventSubscriptionsByProcessInstanceAndActivityId in interface EventSubscriptionService

findEventSubscriptionsByTypeAndProcessDefinitionId

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

Specified by:

findEventSubscriptionsByTypeAndProcessDefinitionId in interface EventSubscriptionService

findEventSubscriptionsByExecutionAndType

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

Specified by:

findEventSubscriptionsByExecutionAndType in interface EventSubscriptionService

findSignalEventSubscriptionsByProcessInstanceAndEventName

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

Specified by:

findSignalEventSubscriptionsByProcessInstanceAndEventName in interface EventSubscriptionService

findSignalEventSubscriptionsByScopeAndEventName

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

Specified by:

findSignalEventSubscriptionsByScopeAndEventName in interface EventSubscriptionService

findSignalEventSubscriptionsByEventName

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

Specified by:

findSignalEventSubscriptionsByEventName in interface EventSubscriptionService

findSignalEventSubscriptionsByNameAndExecution

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

Specified by:

findSignalEventSubscriptionsByNameAndExecution in interface EventSubscriptionService

findMessageEventSubscriptionsByProcessInstanceAndEventName

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

Specified by:

findMessageEventSubscriptionsByProcessInstanceAndEventName in interface EventSubscriptionService

findMessageStartEventSubscriptionByName

public MessageEventSubscriptionEntity findMessageStartEventSubscriptionByName(String eventName,
 String tenantId)

Specified by:

findMessageStartEventSubscriptionByName in interface EventSubscriptionService

findCompensateEventSubscriptionsByExecutionId

public List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByExecutionId(String executionId)

Specified by:

findCompensateEventSubscriptionsByExecutionId in interface EventSubscriptionService

findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId

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

Specified by:

findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId in interface EventSubscriptionService

findEventSubscriptionsByQueryCriteria

public List<EventSubscription> findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQuery)

Specified by:

findEventSubscriptionsByQueryCriteria in interface EventSubscriptionService

createSignalEventSubscription

public SignalEventSubscriptionEntity createSignalEventSubscription()

Specified by:

createSignalEventSubscription in interface EventSubscriptionService

createMessageEventSubscription

public MessageEventSubscriptionEntity createMessageEventSubscription()

Specified by:

createMessageEventSubscription in interface EventSubscriptionService

createEventSubscriptionBuilder

public EventSubscriptionBuilder createEventSubscriptionBuilder()

Specified by:

createEventSubscriptionBuilder in interface EventSubscriptionService

insertEventSubscription

public void insertEventSubscription(EventSubscriptionEntity eventSubscription)

Specified by:

insertEventSubscription in interface EventSubscriptionService

updateEventSubscriptionTenantId

public void updateEventSubscriptionTenantId(String oldTenantId,
 String newTenantId)

Specified by:

updateEventSubscriptionTenantId in interface EventSubscriptionService

updateEventSubscriptionProcessDefinitionId

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

Specified by:

updateEventSubscriptionProcessDefinitionId in interface EventSubscriptionService

updateEventSubscriptionScopeDefinitionId

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

Specified by:

updateEventSubscriptionScopeDefinitionId in interface EventSubscriptionService

updateEventSubscription

public void updateEventSubscription(EventSubscriptionEntity eventSubscription)

Specified by:

updateEventSubscription in interface EventSubscriptionService

lockEventSubscription

public boolean lockEventSubscription(String eventSubscriptionId)

Specified by:

lockEventSubscription in interface EventSubscriptionService

unlockEventSubscription

public void unlockEventSubscription(String eventSubscriptionId)

Specified by:

unlockEventSubscription in interface EventSubscriptionService

deleteEventSubscription

public void deleteEventSubscription(EventSubscriptionEntity eventSubscription)

Specified by:

deleteEventSubscription in interface EventSubscriptionService

deleteEventSubscriptionsByExecutionId

public void deleteEventSubscriptionsByExecutionId(String executionId)

Specified by:

deleteEventSubscriptionsByExecutionId in interface EventSubscriptionService

deleteEventSubscriptionsForScopeIdAndType

public void deleteEventSubscriptionsForScopeIdAndType(String scopeId,
 String scopeType)

Specified by:

deleteEventSubscriptionsForScopeIdAndType in interface EventSubscriptionService

deleteEventSubscriptionsForProcessDefinition

public void deleteEventSubscriptionsForProcessDefinition(String processDefinitionId)

Specified by:

deleteEventSubscriptionsForProcessDefinition in interface EventSubscriptionService

deleteEventSubscriptionsForScopeDefinitionIdAndType

public void deleteEventSubscriptionsForScopeDefinitionIdAndType(String scopeDefinitionId,
 String scopeType)

Specified by:

deleteEventSubscriptionsForScopeDefinitionIdAndType in interface EventSubscriptionService

deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId

public void deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId(String scopeDefinitionId,
 String scopeType)

Specified by:

deleteEventSubscriptionsForScopeDefinitionIdAndTypeAndNullScopeId in interface EventSubscriptionService

deleteEventSubscriptionsForProcessDefinitionAndProcessStartEvent

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

Specified by:

deleteEventSubscriptionsForProcessDefinitionAndProcessStartEvent in interface EventSubscriptionService

deleteEventSubscriptionsForScopeDefinitionAndScopeStartEvent

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

Specified by:

deleteEventSubscriptionsForScopeDefinitionAndScopeStartEvent in interface EventSubscriptionService

createEventSubscription

public EventSubscription createEventSubscription(EventSubscriptionBuilder builder)

getEventSubscriptionEntityManager

public EventSubscriptionEntityManager getEventSubscriptionEntityManager()