org.camunda.bpm.engine.impl.persistence.entity

Class EventSubscriptionManager

java.lang.Object

org.camunda.bpm.engine.impl.persistence.AbstractManager

org.camunda.bpm.engine.impl.persistence.entity.EventSubscriptionManager

All Implemented Interfaces:

Session

public class EventSubscriptionManager
extends AbstractManager

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field and Description
protected List<EventSubscriptionEntity>	createdSignalSubscriptions keep track of subscriptions created in the current command
protected static EnginePersistenceLogger	LOG

Constructor Summary

Constructors

Constructor and Description
EventSubscriptionManager()

Method Summary

Methods

Modifier and Type	Method and Description
protected ListQueryParameterObject	configureParameterizedQuery(Object parameter)
protected void	configureQuery(EventSubscriptionQueryImpl query)
void	deleteAndFlushEventSubscription(EventSubscriptionEntity persistentObject)
void	deleteEventSubscription(EventSubscriptionEntity persistentObject)
EventSubscriptionEntity	findEventSubscriptionById(String id)
long	findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)
List<EventSubscriptionEntity>	findEventSubscriptions(String executionId, String type, String activityId)
List<EventSubscriptionEntity>	findEventSubscriptionsByConfiguration(String type, String configuration)
List<EventSubscriptionEntity>	findEventSubscriptionsByExecution(String executionId)
List<EventSubscriptionEntity>	findEventSubscriptionsByExecutionAndType(String executionId, String type, boolean lockResult)
List<EventSubscriptionEntity>	findEventSubscriptionsByNameAndExecution(String type, String eventName, String executionId, boolean lockResult)
List<EventSubscriptionEntity>	findEventSubscriptionsByNameAndTenantId(String type, String eventName, String tenantId)
List<EventSubscriptionEntity>	findEventSubscriptionsByProcessInstanceId(String processInstanceId)
List<EventSubscription>	findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl, Page page)
List<EventSubscriptionEntity>	findMessageStartEventSubscriptionByName(String messageName)
EventSubscriptionEntity	findMessageStartEventSubscriptionByNameAndTenantId(String messageName, String tenantId)
List<EventSubscriptionEntity>	findSignalEventSubscriptionsByEventName(String eventName) Find all signal event subscriptions with the given event name for any tenant.
List<EventSubscriptionEntity>	findSignalEventSubscriptionsByEventNameAndTenantId(String eventName, String tenantId) Find all signal event subscriptions with the given event name and tenant.
List<EventSubscriptionEntity>	findSignalEventSubscriptionsByEventNameAndTenantIdIncludeWithoutTenantId(String eventName, String tenantId) Find all signal event subscriptions with the given event name which belongs to the given tenant or no tenant.
List<EventSubscriptionEntity>	findSignalEventSubscriptionsByExecution(String executionId)
List<EventSubscriptionEntity>	findSignalEventSubscriptionsByNameAndExecution(String name, String executionId)
protected boolean	hasTenantId(EventSubscriptionEntity entity, String tenantId)
void	insert(EventSubscriptionEntity persistentObject)
protected boolean	matchesSubscription(EventSubscriptionEntity subscription, String type, String eventName)

Methods inherited from class org.camunda.bpm.engine.impl.persistence.AbstractManager

checkAuthorization, close, configureQuery, delete, deleteAuthorizations, deleteAuthorizationsForGroup, deleteAuthorizationsForUser, deleteDefaultAuthorizations, flush, getAttachmentManager, getAuthorizationManager, getBatchManager, getByteArrayManager, getCaseDefinitionManager, getCaseExecutionManager, getCaseInstanceManager, getCommandContext, getCurrentAuthentication, getDbEntityManager, getDbSqlSession, getDecisionDefinitionManager, getDeploymentManager, getEventSubscriptionManager, getHistoricActivityInstanceManager, getHistoricBatchManager, getHistoricCaseActivityInstanceManager, getHistoricCaseInstanceManager, getHistoricDecisionInstanceManager, getHistoricDetailManager, getHistoricIdentityLinkManager, getHistoricIncidentManager, getHistoricJobLogManager, getHistoricProcessInstanceManager, getHistoricReportManager, getHistoricTaskInstanceManager, getHistoricVariableInstanceManager, getIdentityInfoManager, getIdentityLinkManager, getJobDefinitionManager, getJobManager, getProcessDefinitionManager, getProcessInstanceManager, getResourceAuthorizationProvider, getResourceManager, getSession, getTaskManager, getTaskReportManager, getTenantManager, getUserOperationLogManager, getVariableInstanceManager, insert, isAuthorizationEnabled, saveDefaultAuthorizations

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final EnginePersistenceLogger LOG

createdSignalSubscriptions

protected List<EventSubscriptionEntity> createdSignalSubscriptions

keep track of subscriptions created in the current command

Constructor Detail

EventSubscriptionManager

public EventSubscriptionManager()

Method Detail

insert

public void insert(EventSubscriptionEntity persistentObject)

deleteEventSubscription

public void deleteEventSubscription(EventSubscriptionEntity persistentObject)

deleteAndFlushEventSubscription

public void deleteAndFlushEventSubscription(EventSubscriptionEntity persistentObject)

findEventSubscriptionById

public EventSubscriptionEntity findEventSubscriptionById(String id)

findEventSubscriptionCountByQueryCriteria

public long findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)

findEventSubscriptionsByQueryCriteria

public List<EventSubscription> findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl,
                                                            Page page)

findSignalEventSubscriptionsByEventName

public List<EventSubscriptionEntity> findSignalEventSubscriptionsByEventName(String eventName)

Find all signal event subscriptions with the given event name for any tenant.

See Also:

findSignalEventSubscriptionsByEventNameAndTenantId(String, String)

findSignalEventSubscriptionsByEventNameAndTenantId

public List<EventSubscriptionEntity> findSignalEventSubscriptionsByEventNameAndTenantId(String eventName,
                                                                               String tenantId)

Find all signal event subscriptions with the given event name and tenant.

findSignalEventSubscriptionsByEventNameAndTenantIdIncludeWithoutTenantId

public List<EventSubscriptionEntity> findSignalEventSubscriptionsByEventNameAndTenantIdIncludeWithoutTenantId(String eventName,
                                                                                                     String tenantId)

Find all signal event subscriptions with the given event name which belongs to the given tenant or no tenant.

hasTenantId

protected boolean hasTenantId(EventSubscriptionEntity entity,
                  String tenantId)

findSignalEventSubscriptionsByExecution

public List<EventSubscriptionEntity> findSignalEventSubscriptionsByExecution(String executionId)

findSignalEventSubscriptionsByNameAndExecution

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

findEventSubscriptionsByExecutionAndType

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

findEventSubscriptionsByExecution

public List<EventSubscriptionEntity> findEventSubscriptionsByExecution(String executionId)

findEventSubscriptions

public List<EventSubscriptionEntity> findEventSubscriptions(String executionId,
                                                   String type,
                                                   String activityId)

findEventSubscriptionsByConfiguration

public List<EventSubscriptionEntity> findEventSubscriptionsByConfiguration(String type,
                                                                  String configuration)

findEventSubscriptionsByNameAndTenantId

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

findEventSubscriptionsByNameAndExecution

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

findEventSubscriptionsByProcessInstanceId

public List<EventSubscriptionEntity> findEventSubscriptionsByProcessInstanceId(String processInstanceId)

findMessageStartEventSubscriptionByName

public List<EventSubscriptionEntity> findMessageStartEventSubscriptionByName(String messageName)

Returns:

the message start event subscriptions with the given message name (from any tenant)

See Also:

findMessageStartEventSubscriptionByNameAndTenantId(String, String)

findMessageStartEventSubscriptionByNameAndTenantId

public EventSubscriptionEntity findMessageStartEventSubscriptionByNameAndTenantId(String messageName,
                                                                         String tenantId)

Returns:

the message start event subscription with the given message name and tenant id

See Also:

findMessageStartEventSubscriptionByName(String)

configureQuery

protected void configureQuery(EventSubscriptionQueryImpl query)

configureParameterizedQuery

protected ListQueryParameterObject configureParameterizedQuery(Object parameter)

matchesSubscription

protected boolean matchesSubscription(EventSubscriptionEntity subscription,
                          String type,
                          String eventName)