Uses of Class
org.camunda.bpm.engine.impl.persistence.entity.EventSubscriptionEntity
Package
Description
-
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.bpmn.behavior
Modifier and TypeMethodDescriptionprotected List<EventSubscriptionEntity>
CompensationEventActivityBehavior.collectEventSubscriptions
(ActivityExecution execution) protected List<EventSubscriptionEntity>
ThrowSignalEventActivityBehavior.findSignalEventSubscriptions
(String signalName, String tenantId) Modifier and TypeMethodDescriptionvoid
BpmnBehaviorLogger.ignoringEventSubscription
(EventSubscriptionEntity eventSubscription, String processDefinitionId) protected boolean
ThrowSignalEventActivityBehavior.isActiveEventSubscription
(EventSubscriptionEntity signalEventSubscriptionEntity) protected boolean
ThrowSignalEventActivityBehavior.isActiveIntermediateEventSubscription
(EventSubscriptionEntity signalEventSubscriptionEntity) protected boolean
ThrowSignalEventActivityBehavior.isStartEventSubscription
(EventSubscriptionEntity signalEventSubscriptionEntity) void
BoundaryConditionalEventActivityBehavior.leaveOnSatisfiedCondition
(EventSubscriptionEntity eventSubscription, VariableEvent variableEvent) void
ConditionalEventBehavior.leaveOnSatisfiedCondition
(EventSubscriptionEntity eventSubscription, VariableEvent variableEvent) Checks the condition, on satisfaction the activity is leaved.void
EventSubProcessStartConditionalEventActivityBehavior.leaveOnSatisfiedCondition
(EventSubscriptionEntity eventSubscription, VariableEvent variableEvent) void
IntermediateConditionalEventBehavior.leaveOnSatisfiedCondition
(EventSubscriptionEntity eventSubscription, VariableEvent variableEvent) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.bpmn.deployer
Modifier and TypeMethodDescriptionprotected List<EventSubscriptionEntity>
BpmnDeployer.getOrphanSubscriptionEvents
(ProcessDefinitionEntity processDefinition) protected List<EventSubscriptionEntity>
BpmnDeployer.getPreviousSubscriptionEvents
(ProcessDefinitionEntity latestProcessDefinition) Modifier and TypeMethodDescriptionprotected boolean
BpmnDeployer.hasTenantId
(EventSubscriptionEntity cachedSubscription, String tenantId) protected boolean
BpmnDeployer.isOrphan
(EventSubscriptionEntity entity) protected boolean
BpmnDeployer.isSubscriptionForIntermediateEvent
(EventSubscriptionEntity subscriptionEntity) protected boolean
BpmnDeployer.isSubscriptionForStartEvent
(EventSubscriptionEntity subscriptionEntity) protected boolean
BpmnDeployer.isSubscriptionOfDifferentTypeAsDeclaration
(EventSubscriptionEntity subscriptionEntity, EventSubscriptionDeclaration declaration) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.bpmn.helper
Modifier and TypeMethodDescriptionstatic List<EventSubscriptionEntity>
CompensationUtil.collectCompensateEventSubscriptionsForActivity
(ActivityExecution execution, String activityRef) Collect all compensate event subscriptions for activity on the scope of given execution.static List<EventSubscriptionEntity>
CompensationUtil.collectCompensateEventSubscriptionsForScope
(ActivityExecution execution) Collect all compensate event subscriptions for scope of given execution.Modifier and TypeMethodDescriptionstatic ExecutionEntity
CompensationUtil.getCompensatingExecution
(EventSubscriptionEntity eventSubscription) Modifier and TypeMethodDescriptionstatic void
CompensationUtil.throwCompensationEvent
(List<EventSubscriptionEntity> eventSubscriptions, ActivityExecution execution, boolean async) we create a separate execution for each compensation handler invocation. -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.bpmn.parser
Modifier and TypeMethodDescriptionEventSubscriptionDeclaration.createSubscriptionForExecution
(ExecutionEntity execution) Creates and inserts a subscription entity depending on the message type of this declaration.EventSubscriptionDeclaration.createSubscriptionForStartEvent
(ProcessDefinitionEntity processDefinition) Modifier and TypeMethodDescriptionvoid
EventSubscriptionDeclaration.updateSubscription
(EventSubscriptionEntity eventSubscription) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.cmd
Modifier and TypeMethodDescriptionprotected List<EventSubscriptionEntity>
SignalEventReceivedCmd.filterIntermediateSubscriptions
(List<EventSubscriptionEntity> subscriptions) protected List<EventSubscriptionEntity>
SignalEventReceivedCmd.filterStartSubscriptions
(List<EventSubscriptionEntity> subscriptions) protected List<EventSubscriptionEntity>
SignalEventReceivedCmd.findSignalEventSubscriptions
(CommandContext commandContext, String signalName) Modifier and TypeMethodDescriptionvoid
CommandLogger.couldNotFindProcessDefinitionForEventSubscription
(EventSubscriptionEntity messageEventSubscription, String processDefinitionId) void
CommandLogger.debugIgnoringEventSubscription
(EventSubscriptionEntity eventSubscription, String processDefinitionId) Modifier and TypeMethodDescriptionprotected void
SignalEventReceivedCmd.checkAuthorizationOfCatchSignals
(CommandContext commandContext, List<EventSubscriptionEntity> catchSignalEventSubscription) protected List<EventSubscriptionEntity>
SignalEventReceivedCmd.filterIntermediateSubscriptions
(List<EventSubscriptionEntity> subscriptions) protected List<EventSubscriptionEntity>
SignalEventReceivedCmd.filterStartSubscriptions
(List<EventSubscriptionEntity> subscriptions) protected Map<String,
ProcessDefinitionEntity> SignalEventReceivedCmd.getProcessDefinitionsOfSubscriptions
(List<EventSubscriptionEntity> startSignalEventSubscriptions) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.event
Modifier and TypeMethodDescriptionvoid
CompensationEventHandler.handleEvent
(EventSubscriptionEntity eventSubscription, Object payload, Object localPayload, Object payloadToTriggeredScope, String businessKey, CommandContext commandContext) void
ConditionalEventHandler.handleEvent
(EventSubscriptionEntity eventSubscription, Object payload, Object localPayload, Object payloadToTriggeredScope, String businessKey, CommandContext commandContext) void
EventHandler.handleEvent
(EventSubscriptionEntity eventSubscription, Object payload, Object localPayload, Object payloadToTriggeredScope, String businessKey, CommandContext commandContext) void
EventHandlerImpl.handleEvent
(EventSubscriptionEntity eventSubscription, Object payload, Object localPayload, Object payloadToTriggeredScope, String businessKey, CommandContext commandContext) void
SignalEventHandler.handleEvent
(EventSubscriptionEntity eventSubscription, Object payload, Object payloadLocal, Object payloadToTriggeredScope, String businessKey, CommandContext commandContext) void
EventHandlerImpl.handleIntermediateEvent
(EventSubscriptionEntity eventSubscription, Object payload, Object localPayload, Object payloadToTriggeredScope, CommandContext commandContext) protected void
SignalEventHandler.handleStartEvent
(EventSubscriptionEntity eventSubscription, Map<String, Object> payload, String businessKey, CommandContext commandContext) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.jobexecutor
Modifier and TypeMethodDescriptionEventSubscriptionJobDeclaration.findDeclarationForSubscription
(EventSubscriptionEntity eventSubscription) Assumes that an activity has at most one declaration of a certain eventType.protected MessageEntity
EventSubscriptionJobDeclaration.newJobInstance
(EventSubscriptionEntity eventSubscription) protected ExecutionEntity
EventSubscriptionJobDeclaration.resolveExecution
(EventSubscriptionEntity context) protected JobHandlerConfiguration
EventSubscriptionJobDeclaration.resolveJobHandlerConfiguration
(EventSubscriptionEntity context) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.migration.instance
Modifier and TypeFieldDescriptionprotected EventSubscriptionEntity
MigratingCompensationEventSubscriptionInstance.eventSubscription
protected EventSubscriptionEntity
MigratingEventSubscriptionInstance.eventSubscriptionEntity
Modifier and TypeMethodDescriptionMigratingProcessInstance.addCompensationSubscriptionInstance
(MigrationInstruction eventSubscriptionInstruction, EventSubscriptionEntity eventSubscription, ScopeImpl sourceScope, ScopeImpl targetScope) MigratingProcessInstance.addEventScopeInstance
(MigrationInstruction migrationInstruction, ExecutionEntity eventScopeExecution, ScopeImpl sourceScope, ScopeImpl targetScope, MigrationInstruction eventSubscriptionInstruction, EventSubscriptionEntity eventSubscription, ScopeImpl eventSubscriptionSourceScope, ScopeImpl eventSubscriptionTargetScope) ModifierConstructorDescriptionMigratingCompensationEventSubscriptionInstance
(MigrationInstruction migrationInstruction, ScopeImpl sourceScope, ScopeImpl targetScope, EventSubscriptionEntity eventSubscription) MigratingEventScopeInstance
(EventSubscriptionEntity eventSubscription, ExecutionEntity eventScopeExecution, ScopeImpl targetScope) Creates an emerged scopeMigratingEventScopeInstance
(MigrationInstruction migrationInstruction, ExecutionEntity eventScopeExecution, ScopeImpl sourceScope, ScopeImpl targetScope, MigrationInstruction eventSubscriptionInstruction, EventSubscriptionEntity eventSubscription, ScopeImpl eventSubscriptionSourceScope, ScopeImpl eventSubscriptionTargetScope) MigratingEventSubscriptionInstance
(EventSubscriptionEntity eventSubscriptionEntity) MigratingEventSubscriptionInstance
(EventSubscriptionEntity eventSubscriptionEntity, ScopeImpl targetScope, boolean updateEvent, EventSubscriptionDeclaration targetDeclaration) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.migration.instance.parser
Modifier and TypeFieldDescriptionMigratingInstanceParser.compensationInstanceHandler
protected MigratingDependentInstanceParseHandler<MigratingActivityInstance,
List<EventSubscriptionEntity>> MigratingInstanceParser.dependentEventSubscriptionHandler
protected Collection<EventSubscriptionEntity>
MigratingInstanceParseContext.eventSubscriptions
Modifier and TypeMethodDescriptionprotected List<EventSubscriptionEntity>
ActivityInstanceHandler.collectActivityInstanceEventSubscriptions
(MigratingActivityInstance migratingInstance) protected static List<EventSubscriptionEntity>
CompensationEventSubscriptionWalker.collectCompensationEventSubscriptions
(Collection<MigratingActivityInstance> activityInstances) protected List<EventSubscriptionEntity>
MigratingInstanceParser.fetchEventSubscriptions
(CommandContext commandContext, String processInstanceId) MigratingInstanceParser.getDependentEventSubscriptionHandler()
protected Collection<EventSubscriptionEntity>
CompensationEventSubscriptionWalker.nextElements()
Modifier and TypeMethodDescriptionvoid
MigratingInstanceParseContext.consume
(EventSubscriptionEntity eventSubscription) protected MigratingProcessElementInstance
CompensationInstanceHandler.createMigratingEventScopeInstance
(MigratingInstanceParseContext parseContext, EventSubscriptionEntity element) protected MigratingProcessElementInstance
CompensationInstanceHandler.createMigratingEventSubscriptionInstance
(MigratingInstanceParseContext parseContext, EventSubscriptionEntity element) void
CompensationInstanceHandler.handle
(MigratingInstanceParseContext parseContext, EventSubscriptionEntity element) Modifier and TypeMethodDescriptionMigratingInstanceParseContext.eventSubscriptions
(Collection<EventSubscriptionEntity> eventSubscriptions) void
EventSubscriptionInstanceHandler.handle
(MigratingInstanceParseContext parseContext, MigratingActivityInstance owningInstance, List<EventSubscriptionEntity> elements) void
MigratingInstanceParseContext.handleDependentEventSubscriptions
(MigratingActivityInstance migratingInstance, List<EventSubscriptionEntity> eventSubscriptions) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.persistence.entity
Modifier and TypeFieldDescriptionprotected List<EventSubscriptionEntity>
EventSubscriptionManager.createdSignalSubscriptions
keep track of subscriptions created in the current commandprotected List<EventSubscriptionEntity>
ExecutionEntity.eventSubscriptions
Modifier and TypeMethodDescriptionstatic EventSubscriptionEntity
EventSubscriptionEntity.createAndInsert
(ExecutionEntity executionEntity, EventType eventType, ActivityImpl activity) static EventSubscriptionEntity
EventSubscriptionEntity.createAndInsert
(ExecutionEntity executionEntity, EventType eventType, ActivityImpl activity, String configuration) EventSubscriptionManager.findEventSubscriptionById
(String id) EventSubscriptionManager.findMessageStartEventSubscriptionByNameAndTenantId
(String messageName, String tenantId) Modifier and TypeMethodDescriptionEventSubscriptionManager.findConditionalStartEventSubscription()
EventSubscriptionManager.findConditionalStartEventSubscriptionByTenantId
(String tenantId) EventSubscriptionManager.findEventSubscriptions
(String executionId, String type, String activityId) EventSubscriptionManager.findEventSubscriptionsByConfiguration
(String type, String configuration) EventSubscriptionManager.findEventSubscriptionsByExecution
(String executionId) EventSubscriptionManager.findEventSubscriptionsByExecutionAndType
(String executionId, String type, boolean lockResult) EventSubscriptionManager.findEventSubscriptionsByNameAndExecution
(String type, String eventName, String executionId, boolean lockResult) EventSubscriptionManager.findEventSubscriptionsByNameAndTenantId
(String type, String eventName, String tenantId) EventSubscriptionManager.findEventSubscriptionsByProcessInstanceId
(String processInstanceId) EventSubscriptionManager.findMessageStartEventSubscriptionByName
(String messageName) EventSubscriptionManager.findSignalEventSubscriptionsByEventName
(String eventName) Find all signal event subscriptions with the given event name for any tenant.EventSubscriptionManager.findSignalEventSubscriptionsByEventNameAndTenantId
(String eventName, String tenantId) Find all signal event subscriptions with the given event name and tenant.EventSubscriptionManager.findSignalEventSubscriptionsByEventNameAndTenantIdIncludeWithoutTenantId
(String eventName, String tenantId) Find all signal event subscriptions with the given event name which belongs to the given tenant or no tenant.EventSubscriptionManager.findSignalEventSubscriptionsByExecution
(String executionId) EventSubscriptionManager.findSignalEventSubscriptionsByNameAndExecution
(String name, String executionId) ExecutionEntity.getCompensateEventSubscriptions()
ExecutionEntity.getCompensateEventSubscriptions
(String activityId) ExecutionEntity.getEventSubscriptions()
ExecutionEntity.getEventSubscriptionsInternal()
Modifier and TypeMethodDescriptionvoid
ExecutionEntity.addEventSubscription
(EventSubscriptionEntity eventSubscriptionEntity) void
EventSubscriptionManager.deleteAndFlushEventSubscription
(EventSubscriptionEntity persistentObject) void
EventSubscriptionManager.deleteEventSubscription
(EventSubscriptionEntity persistentObject) protected boolean
EventSubscriptionManager.hasTenantId
(EventSubscriptionEntity entity, String tenantId) void
EventSubscriptionManager.insert
(EventSubscriptionEntity persistentObject) protected boolean
EventSubscriptionManager.matchesSubscription
(EventSubscriptionEntity subscription, String type, String eventName) void
ExecutionEntity.removeEventSubscription
(EventSubscriptionEntity eventSubscriptionEntity) -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.pvm.runtime
Modifier and TypeMethodDescriptionprotected static boolean
LegacyBehavior.areEqualEventSubscriptions
(EventSubscriptionEntity subscription1, EventSubscriptionEntity subscription2) Checks if the parameters are the same apart from the execution idstatic void
LegacyBehavior.removeLegacySubscriptionOnParent
(ExecutionEntity execution, EventSubscriptionEntity eventSubscription) Required for migrating active sequential MI receive tasks. -
Uses of EventSubscriptionEntity in org.camunda.bpm.engine.impl.runtime
Modifier and TypeMethodDescriptionprotected List<EventSubscriptionEntity>
DefaultConditionHandler.findConditionalStartEventSubscriptions
(CommandContext commandContext, ConditionSet conditionSet) protected List<EventSubscriptionEntity>
DefaultCorrelationHandler.findMessageStartEventSubscriptions
(CommandContext commandContext, String messageName, CorrelationSet correlationSet)