Package 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	Description
protected java.util.List<EventSubscriptionEntity>	createdSignalSubscriptions	keep track of subscriptions created in the current command
protected static EnginePersistenceLogger	LOG

Constructor Summary

Constructors

Constructor	Description
EventSubscriptionManager()

Method Summary

Modifier and Type	Method	Description
protected ListQueryParameterObject	configureParameterizedQuery(java.lang.Object parameter)
protected void	configureQuery(EventSubscriptionQueryImpl query)
protected void	configurParameterObject(ListQueryParameterObject parameter)
void	deleteAndFlushEventSubscription(EventSubscriptionEntity persistentObject)
void	deleteEventSubscription(EventSubscriptionEntity persistentObject)
java.util.List<EventSubscriptionEntity>	findConditionalStartEventSubscription()
java.util.List<EventSubscriptionEntity>	findConditionalStartEventSubscriptionByTenantId(java.lang.String tenantId)
EventSubscriptionEntity	findEventSubscriptionById(java.lang.String id)
long	findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)
java.util.List<EventSubscriptionEntity>	findEventSubscriptions(java.lang.String executionId, java.lang.String type, java.lang.String activityId)
java.util.List<EventSubscriptionEntity>	findEventSubscriptionsByConfiguration(java.lang.String type, java.lang.String configuration)
java.util.List<EventSubscriptionEntity>	findEventSubscriptionsByExecution(java.lang.String executionId)
java.util.List<EventSubscriptionEntity>	findEventSubscriptionsByExecutionAndType(java.lang.String executionId, java.lang.String type, boolean lockResult)
java.util.List<EventSubscriptionEntity>	findEventSubscriptionsByNameAndExecution(java.lang.String type, java.lang.String eventName, java.lang.String executionId, boolean lockResult)
java.util.List<EventSubscriptionEntity>	findEventSubscriptionsByNameAndTenantId(java.lang.String type, java.lang.String eventName, java.lang.String tenantId)
java.util.List<EventSubscriptionEntity>	findEventSubscriptionsByProcessInstanceId(java.lang.String processInstanceId)
java.util.List<EventSubscription>	findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl, Page page)
java.util.List<EventSubscriptionEntity>	findMessageStartEventSubscriptionByName(java.lang.String messageName)
EventSubscriptionEntity	findMessageStartEventSubscriptionByNameAndTenantId(java.lang.String messageName, java.lang.String tenantId)
java.util.List<EventSubscriptionEntity>	findSignalEventSubscriptionsByEventName(java.lang.String eventName)	Find all signal event subscriptions with the given event name for any tenant.
java.util.List<EventSubscriptionEntity>	findSignalEventSubscriptionsByEventNameAndTenantId(java.lang.String eventName, java.lang.String tenantId)	Find all signal event subscriptions with the given event name and tenant.
java.util.List<EventSubscriptionEntity>	findSignalEventSubscriptionsByEventNameAndTenantIdIncludeWithoutTenantId(java.lang.String eventName, java.lang.String tenantId)	Find all signal event subscriptions with the given event name which belongs to the given tenant or no tenant.
java.util.List<EventSubscriptionEntity>	findSignalEventSubscriptionsByExecution(java.lang.String executionId)
java.util.List<EventSubscriptionEntity>	findSignalEventSubscriptionsByNameAndExecution(java.lang.String name, java.lang.String executionId)
protected boolean	hasTenantId(EventSubscriptionEntity entity, java.lang.String tenantId)
void	insert(EventSubscriptionEntity persistentObject)
protected boolean	matchesSubscription(EventSubscriptionEntity subscription, java.lang.String type, java.lang.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, getCamundaFormDefinitionManager, getCaseDefinitionManager, getCaseExecutionManager, getCaseInstanceManager, getCommandContext, getCurrentAuthentication, getDbEntityManager, getDbSqlSession, getDecisionDefinitionManager, getDecisionRequirementsDefinitionManager, getDeploymentManager, getEventSubscriptionManager, getHistoricActivityInstanceManager, getHistoricBatchManager, getHistoricCaseActivityInstanceManager, getHistoricCaseInstanceManager, getHistoricDecisionInstanceManager, getHistoricDetailManager, getHistoricExternalTaskLogManager, 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 java.util.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(java.lang.String id)

findEventSubscriptionCountByQueryCriteria

public long findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)

findEventSubscriptionsByQueryCriteria

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

findSignalEventSubscriptionsByEventName

public java.util.List<EventSubscriptionEntity> findSignalEventSubscriptionsByEventName(java.lang.String eventName)

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

See Also:

findSignalEventSubscriptionsByEventNameAndTenantId(String, String)

findSignalEventSubscriptionsByEventNameAndTenantId

public java.util.List<EventSubscriptionEntity> findSignalEventSubscriptionsByEventNameAndTenantId(java.lang.String eventName,
                                                                                                  java.lang.String tenantId)

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

findSignalEventSubscriptionsByEventNameAndTenantIdIncludeWithoutTenantId

public java.util.List<EventSubscriptionEntity> findSignalEventSubscriptionsByEventNameAndTenantIdIncludeWithoutTenantId(java.lang.String eventName,
                                                                                                                        java.lang.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,
                              java.lang.String tenantId)

findSignalEventSubscriptionsByExecution

public java.util.List<EventSubscriptionEntity> findSignalEventSubscriptionsByExecution(java.lang.String executionId)

findSignalEventSubscriptionsByNameAndExecution

public java.util.List<EventSubscriptionEntity> findSignalEventSubscriptionsByNameAndExecution(java.lang.String name,
                                                                                              java.lang.String executionId)

findEventSubscriptionsByExecutionAndType

public java.util.List<EventSubscriptionEntity> findEventSubscriptionsByExecutionAndType(java.lang.String executionId,
                                                                                        java.lang.String type,
                                                                                        boolean lockResult)

findEventSubscriptionsByExecution

public java.util.List<EventSubscriptionEntity> findEventSubscriptionsByExecution(java.lang.String executionId)

findEventSubscriptions

public java.util.List<EventSubscriptionEntity> findEventSubscriptions(java.lang.String executionId,
                                                                      java.lang.String type,
                                                                      java.lang.String activityId)

findEventSubscriptionsByConfiguration

public java.util.List<EventSubscriptionEntity> findEventSubscriptionsByConfiguration(java.lang.String type,
                                                                                     java.lang.String configuration)

findEventSubscriptionsByNameAndTenantId

public java.util.List<EventSubscriptionEntity> findEventSubscriptionsByNameAndTenantId(java.lang.String type,
                                                                                       java.lang.String eventName,
                                                                                       java.lang.String tenantId)

findEventSubscriptionsByNameAndExecution

public java.util.List<EventSubscriptionEntity> findEventSubscriptionsByNameAndExecution(java.lang.String type,
                                                                                        java.lang.String eventName,
                                                                                        java.lang.String executionId,
                                                                                        boolean lockResult)

findEventSubscriptionsByProcessInstanceId

public java.util.List<EventSubscriptionEntity> findEventSubscriptionsByProcessInstanceId(java.lang.String processInstanceId)

findMessageStartEventSubscriptionByName

public java.util.List<EventSubscriptionEntity> findMessageStartEventSubscriptionByName(java.lang.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(java.lang.String messageName,
                                                                                  java.lang.String tenantId)

Returns:

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

See Also:

findMessageStartEventSubscriptionByName(String)

findConditionalStartEventSubscriptionByTenantId

public java.util.List<EventSubscriptionEntity> findConditionalStartEventSubscriptionByTenantId(java.lang.String tenantId)

Parameters:

tenantId -

Returns:

the conditional start event subscriptions with the given tenant id

findConditionalStartEventSubscription

public java.util.List<EventSubscriptionEntity> findConditionalStartEventSubscription()

Returns:

the conditional start event subscriptions (from any tenant)

configurParameterObject

protected void configurParameterObject(ListQueryParameterObject parameter)

configureQuery

protected void configureQuery(EventSubscriptionQueryImpl query)

configureParameterizedQuery

protected ListQueryParameterObject configureParameterizedQuery(java.lang.Object parameter)

matchesSubscription

protected boolean matchesSubscription(EventSubscriptionEntity subscription,
                                      java.lang.String type,
                                      java.lang.String eventName)