public class EventSubscriptionEntityManagerImpl extends AbstractEntityManager<EventSubscriptionEntity> implements EventSubscriptionEntityManager
| Modifier and Type | Field and Description |
|---|---|
protected EventSubscriptionDataManager |
eventSubscriptionDataManager |
processEngineConfiguration| Constructor and Description |
|---|
EventSubscriptionEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration,
EventSubscriptionDataManager eventSubscriptionDataManager) |
create, delete, delete, delete, findById, insert, insert, update, updategetAsyncExecutor, getAttachmentEntityManager, getByteArrayEntityManager, getClock, getCommandContext, getCommandExecutor, getCommentEntityManager, getDeploymentEntityManager, getEventDispatcher, getEventSubscriptionEntityManager, getExecutionEntityManager, getGroupEntityManager, getHistoricActivityInstanceEntityManager, getHistoricDetailEntityManager, getHistoricIdentityLinkEntityManager, getHistoricProcessInstanceEntityManager, getHistoricTaskInstanceEntityManager, getHistoricVariableInstanceEntityManager, getHistoryManager, getIdentityInfoEntityManager, getIdentityLinkEntityManager, getJobEntityManager, getJobExecutor, getMembershipEntityManager, getModelEntityManager, getProcessDefinitionEntityManager, getProcessDefinitionInfoEntityManager, getProcessEngineConfiguration, getResourceEntityManager, getSession, getTaskEntityManager, getUserIdentityEntityManager, getVariableInstanceEntityManagerprotected EventSubscriptionDataManager eventSubscriptionDataManager
public EventSubscriptionEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration, EventSubscriptionDataManager eventSubscriptionDataManager)
protected DataManager<EventSubscriptionEntity> getDataManager()
getDataManager in class AbstractEntityManager<EventSubscriptionEntity>public CompensateEventSubscriptionEntity createCompensateEventSubscription()
createCompensateEventSubscription in interface EventSubscriptionEntityManagerpublic MessageEventSubscriptionEntity createMessageEventSubscription()
createMessageEventSubscription in interface EventSubscriptionEntityManagerpublic SignalEventSubscriptionEntity createSignalEventSubscription()
createSignalEventSubscription in interface EventSubscriptionEntityManagerpublic SignalEventSubscriptionEntity insertSignalEvent(org.activiti.bpmn.model.SignalEventDefinition signalEventDefinition, org.activiti.bpmn.model.Signal signal, ExecutionEntity execution)
insertSignalEvent in interface EventSubscriptionEntityManagerpublic MessageEventSubscriptionEntity insertMessageEvent(org.activiti.bpmn.model.MessageEventDefinition messageEventDefinition, ExecutionEntity execution)
insertMessageEvent in interface EventSubscriptionEntityManagerpublic CompensateEventSubscriptionEntity insertCompensationEvent(ExecutionEntity execution, String activityId)
insertCompensationEvent in interface EventSubscriptionEntityManagerpublic List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByExecutionId(String executionId)
findCompensateEventSubscriptionsByExecutionId in interface EventSubscriptionEntityManagerpublic List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByExecutionIdAndActivityId(String executionId, String activityId)
findCompensateEventSubscriptionsByExecutionIdAndActivityId in interface EventSubscriptionEntityManagerpublic List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId(String processInstanceId, String activityId)
findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId in interface EventSubscriptionEntityManagerprotected void addToExecution(EventSubscriptionEntity eventSubscriptionEntity)
public long findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)
findEventSubscriptionCountByQueryCriteria in interface EventSubscriptionEntityManagerpublic List<EventSubscriptionEntity> findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl, Page page)
findEventSubscriptionsByQueryCriteria in interface EventSubscriptionEntityManagerpublic List<MessageEventSubscriptionEntity> findMessageEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
findMessageEventSubscriptionsByProcessInstanceAndEventName in interface EventSubscriptionEntityManagerpublic List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByEventName(String eventName, String tenantId)
findSignalEventSubscriptionsByEventName in interface EventSubscriptionEntityManagerpublic List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
findSignalEventSubscriptionsByProcessInstanceAndEventName in interface EventSubscriptionEntityManagerpublic List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByExecution(String executionId)
findSignalEventSubscriptionsByExecution in interface EventSubscriptionEntityManagerpublic List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByNameAndExecution(String name, String executionId)
findSignalEventSubscriptionsByNameAndExecution in interface EventSubscriptionEntityManagerpublic List<EventSubscriptionEntity> findEventSubscriptionsByExecutionAndType(String executionId, String type)
findEventSubscriptionsByExecutionAndType in interface EventSubscriptionEntityManagerpublic List<EventSubscriptionEntity> findEventSubscriptionsByProcessInstanceAndActivityId(String processInstanceId, String activityId, String type)
findEventSubscriptionsByProcessInstanceAndActivityId in interface EventSubscriptionEntityManagerpublic List<EventSubscriptionEntity> findEventSubscriptionsByExecution(String executionId)
findEventSubscriptionsByExecution in interface EventSubscriptionEntityManagerpublic List<EventSubscriptionEntity> findEventSubscriptionsByConfiguration(String type, String configuration, String tenantId)
findEventSubscriptionsByConfiguration in interface EventSubscriptionEntityManagerpublic List<EventSubscriptionEntity> findEventSubscriptionsByName(String type, String eventName, String tenantId)
findEventSubscriptionsByName in interface EventSubscriptionEntityManagerpublic List<EventSubscriptionEntity> findEventSubscriptionsByNameAndExecution(String type, String eventName, String executionId)
findEventSubscriptionsByNameAndExecution in interface EventSubscriptionEntityManagerpublic MessageEventSubscriptionEntity findMessageStartEventSubscriptionByName(String messageName, String tenantId)
findMessageStartEventSubscriptionByName in interface EventSubscriptionEntityManagerpublic void updateEventSubscriptionTenantId(String oldTenantId, String newTenantId)
updateEventSubscriptionTenantId in interface EventSubscriptionEntityManagerpublic void deleteEventSubscriptionsForProcessDefinition(String processDefinitionId)
deleteEventSubscriptionsForProcessDefinition in interface EventSubscriptionEntityManagerpublic void eventReceived(EventSubscriptionEntity eventSubscriptionEntity, Object payload, boolean processASync)
eventReceived in interface EventSubscriptionEntityManagerprotected void processEventSync(EventSubscriptionEntity eventSubscriptionEntity, Object payload)
protected void scheduleEventAsync(EventSubscriptionEntity eventSubscriptionEntity, Object payload)
protected List<SignalEventSubscriptionEntity> toSignalEventSubscriptionEntityList(List<EventSubscriptionEntity> result)
protected List<MessageEventSubscriptionEntity> toMessageEventSubscriptionEntityList(List<EventSubscriptionEntity> result)
public EventSubscriptionDataManager getEventSubscriptionDataManager()
public void setEventSubscriptionDataManager(EventSubscriptionDataManager eventSubscriptionDataManager)
Copyright © 2015 Alfresco. All rights reserved.