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, update
getAsyncExecutor, 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, getVariableInstanceEntityManager
protected EventSubscriptionDataManager eventSubscriptionDataManager
public EventSubscriptionEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration, EventSubscriptionDataManager eventSubscriptionDataManager)
protected DataManager<EventSubscriptionEntity> getDataManager()
getDataManager
in class AbstractEntityManager<EventSubscriptionEntity>
public CompensateEventSubscriptionEntity createCompensateEventSubscription()
createCompensateEventSubscription
in interface EventSubscriptionEntityManager
public MessageEventSubscriptionEntity createMessageEventSubscription()
createMessageEventSubscription
in interface EventSubscriptionEntityManager
public SignalEventSubscriptionEntity createSignalEventSubscription()
createSignalEventSubscription
in interface EventSubscriptionEntityManager
public SignalEventSubscriptionEntity insertSignalEvent(org.activiti.bpmn.model.SignalEventDefinition signalEventDefinition, org.activiti.bpmn.model.Signal signal, ExecutionEntity execution)
insertSignalEvent
in interface EventSubscriptionEntityManager
public MessageEventSubscriptionEntity insertMessageEvent(org.activiti.bpmn.model.MessageEventDefinition messageEventDefinition, ExecutionEntity execution)
insertMessageEvent
in interface EventSubscriptionEntityManager
public CompensateEventSubscriptionEntity insertCompensationEvent(ExecutionEntity execution, String activityId)
insertCompensationEvent
in interface EventSubscriptionEntityManager
public List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByExecutionId(String executionId)
findCompensateEventSubscriptionsByExecutionId
in interface EventSubscriptionEntityManager
public List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByExecutionIdAndActivityId(String executionId, String activityId)
findCompensateEventSubscriptionsByExecutionIdAndActivityId
in interface EventSubscriptionEntityManager
public List<CompensateEventSubscriptionEntity> findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId(String processInstanceId, String activityId)
findCompensateEventSubscriptionsByProcessInstanceIdAndActivityId
in interface EventSubscriptionEntityManager
protected void addToExecution(EventSubscriptionEntity eventSubscriptionEntity)
public long findEventSubscriptionCountByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl)
findEventSubscriptionCountByQueryCriteria
in interface EventSubscriptionEntityManager
public List<EventSubscriptionEntity> findEventSubscriptionsByQueryCriteria(EventSubscriptionQueryImpl eventSubscriptionQueryImpl, Page page)
findEventSubscriptionsByQueryCriteria
in interface EventSubscriptionEntityManager
public List<MessageEventSubscriptionEntity> findMessageEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
findMessageEventSubscriptionsByProcessInstanceAndEventName
in interface EventSubscriptionEntityManager
public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByEventName(String eventName, String tenantId)
findSignalEventSubscriptionsByEventName
in interface EventSubscriptionEntityManager
public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByProcessInstanceAndEventName(String processInstanceId, String eventName)
findSignalEventSubscriptionsByProcessInstanceAndEventName
in interface EventSubscriptionEntityManager
public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByExecution(String executionId)
findSignalEventSubscriptionsByExecution
in interface EventSubscriptionEntityManager
public List<SignalEventSubscriptionEntity> findSignalEventSubscriptionsByNameAndExecution(String name, String executionId)
findSignalEventSubscriptionsByNameAndExecution
in interface EventSubscriptionEntityManager
public List<EventSubscriptionEntity> findEventSubscriptionsByExecutionAndType(String executionId, String type)
findEventSubscriptionsByExecutionAndType
in interface EventSubscriptionEntityManager
public List<EventSubscriptionEntity> findEventSubscriptionsByProcessInstanceAndActivityId(String processInstanceId, String activityId, String type)
findEventSubscriptionsByProcessInstanceAndActivityId
in interface EventSubscriptionEntityManager
public List<EventSubscriptionEntity> findEventSubscriptionsByExecution(String executionId)
findEventSubscriptionsByExecution
in interface EventSubscriptionEntityManager
public List<EventSubscriptionEntity> findEventSubscriptionsByConfiguration(String type, String configuration, String tenantId)
findEventSubscriptionsByConfiguration
in interface EventSubscriptionEntityManager
public List<EventSubscriptionEntity> findEventSubscriptionsByName(String type, String eventName, String tenantId)
findEventSubscriptionsByName
in interface EventSubscriptionEntityManager
public List<EventSubscriptionEntity> findEventSubscriptionsByNameAndExecution(String type, String eventName, String executionId)
findEventSubscriptionsByNameAndExecution
in interface EventSubscriptionEntityManager
public MessageEventSubscriptionEntity findMessageStartEventSubscriptionByName(String messageName, String tenantId)
findMessageStartEventSubscriptionByName
in interface EventSubscriptionEntityManager
public void updateEventSubscriptionTenantId(String oldTenantId, String newTenantId)
updateEventSubscriptionTenantId
in interface EventSubscriptionEntityManager
public void deleteEventSubscriptionsForProcessDefinition(String processDefinitionId)
deleteEventSubscriptionsForProcessDefinition
in interface EventSubscriptionEntityManager
public void eventReceived(EventSubscriptionEntity eventSubscriptionEntity, Object payload, boolean processASync)
eventReceived
in interface EventSubscriptionEntityManager
protected 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.