Class EventSubscriptionManager
java.lang.Object
org.flowable.engine.impl.bpmn.deployer.EventSubscriptionManager
Manages event subscriptions for newly-deployed process definitions and their previous versions.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static final record
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
addEventSubscriptions
(ProcessDefinitionEntity processDefinition, Process process, BpmnModel bpmnModel) protected List<EventSubscriptionManager.StartEventInfo>
getEventRegistryStartEventEventTypes
(ProcessDefinitionEntity previousProcessDefinition) protected void
insertEventRegistryEvent
(String eventDefinitionKey, StartEvent startEvent, ProcessDefinitionEntity processDefinition, BpmnModel bpmnModel) protected void
insertMessageEvent
(MessageEventDefinition messageEventDefinition, StartEvent startEvent, ProcessDefinitionEntity processDefinition, BpmnModel bpmnModel) protected void
insertSignalEvent
(SignalEventDefinition signalEventDefinition, StartEvent startEvent, ProcessDefinitionEntity processDefinition, BpmnModel bpmnModel) protected void
removeObsoleteEventSubscriptions
(ProcessDefinitionEntity processDefinition, String eventHandlerType) protected void
removeObsoleteMessageEventSubscriptions
(ProcessDefinitionEntity previousProcessDefinition) protected void
removeObsoleteSignalEventSubscription
(ProcessDefinitionEntity previousProcessDefinition) protected void
removeOrUpdateObsoleteEventRegistryEventSubscription
(ProcessDefinitionEntity previousProcessDefinition, ProcessDefinitionEntity processDefinition) protected void
updateOldEventSubscriptions
(ProcessDefinitionEntity previousProcessDefinition, ProcessDefinitionEntity processDefinition, String eventType, String activityId)
-
Constructor Details
-
EventSubscriptionManager
public EventSubscriptionManager()
-
-
Method Details
-
removeObsoleteMessageEventSubscriptions
protected void removeObsoleteMessageEventSubscriptions(ProcessDefinitionEntity previousProcessDefinition) -
removeObsoleteSignalEventSubscription
protected void removeObsoleteSignalEventSubscription(ProcessDefinitionEntity previousProcessDefinition) -
removeOrUpdateObsoleteEventRegistryEventSubscription
protected void removeOrUpdateObsoleteEventRegistryEventSubscription(ProcessDefinitionEntity previousProcessDefinition, ProcessDefinitionEntity processDefinition) -
getEventRegistryStartEventEventTypes
protected List<EventSubscriptionManager.StartEventInfo> getEventRegistryStartEventEventTypes(ProcessDefinitionEntity previousProcessDefinition) -
removeObsoleteEventSubscriptions
protected void removeObsoleteEventSubscriptions(ProcessDefinitionEntity processDefinition, String eventHandlerType) -
updateOldEventSubscriptions
protected void updateOldEventSubscriptions(ProcessDefinitionEntity previousProcessDefinition, ProcessDefinitionEntity processDefinition, String eventType, String activityId) -
addEventSubscriptions
protected void addEventSubscriptions(ProcessDefinitionEntity processDefinition, Process process, BpmnModel bpmnModel) -
insertSignalEvent
protected void insertSignalEvent(SignalEventDefinition signalEventDefinition, StartEvent startEvent, ProcessDefinitionEntity processDefinition, BpmnModel bpmnModel) -
insertMessageEvent
protected void insertMessageEvent(MessageEventDefinition messageEventDefinition, StartEvent startEvent, ProcessDefinitionEntity processDefinition, BpmnModel bpmnModel) -
insertEventRegistryEvent
protected void insertEventRegistryEvent(String eventDefinitionKey, StartEvent startEvent, ProcessDefinitionEntity processDefinition, BpmnModel bpmnModel)
-