| Modifier and Type | Method and Description | 
|---|---|
protected List<EventSubscriptionEntity> | 
CompensationEventActivityBehavior.collectEventSubscriptions(ActivityExecution execution)  | 
protected List<EventSubscriptionEntity> | 
ThrowSignalEventActivityBehavior.findSignalEventSubscriptions(String signalName,
                            String tenantId)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
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 | 
ConditionalEventBehavior.leaveOnSatisfiedCondition(EventSubscriptionEntity eventSubscription,
                         VariableEvent variableEvent)
Checks the condition, on satisfaction the activity is leaved. 
 | 
void | 
BoundaryConditionalEventActivityBehavior.leaveOnSatisfiedCondition(EventSubscriptionEntity eventSubscription,
                         VariableEvent variableEvent)  | 
void | 
IntermediateConditionalEventBehavior.leaveOnSatisfiedCondition(EventSubscriptionEntity eventSubscription,
                         VariableEvent variableEvent)  | 
void | 
EventSubProcessStartConditionalEventActivityBehavior.leaveOnSatisfiedCondition(EventSubscriptionEntity eventSubscription,
                         VariableEvent variableEvent)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected List<EventSubscriptionEntity> | 
BpmnDeployer.filterSubscriptionsOfDifferentType(EventSubscriptionDeclaration eventSubscription,
                                  List<EventSubscriptionEntity> subscriptionsForSameMessageName)
It is possible to deploy a process containing a start and intermediate
 message event that wait for the same message or to have two processes, one
 with a message start event and the other one with a message intermediate
 event, that subscribe for the same message. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected boolean | 
BpmnDeployer.hasTenantId(EventSubscriptionEntity cachedSubscription,
           String tenantId)  | 
protected boolean | 
BpmnDeployer.isSubscriptionForIntermediateEvent(EventSubscriptionEntity subscriptionEntity)  | 
protected boolean | 
BpmnDeployer.isSubscriptionForStartEvent(EventSubscriptionEntity subscriptionEntity)  | 
protected boolean | 
BpmnDeployer.isSubscriptionOfDifferentTypeAsDeclaration(EventSubscriptionEntity subscriptionEntity,
                                          EventSubscriptionDeclaration declaration)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected List<EventSubscriptionEntity> | 
BpmnDeployer.filterSubscriptionsOfDifferentType(EventSubscriptionDeclaration eventSubscription,
                                  List<EventSubscriptionEntity> subscriptionsForSameMessageName)
It is possible to deploy a process containing a start and intermediate
 message event that wait for the same message or to have two processes, one
 with a message start event and the other one with a message intermediate
 event, that subscribe for the same message. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static 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 Type | Method and Description | 
|---|---|
static ExecutionEntity | 
CompensationUtil.getCompensatingExecution(EventSubscriptionEntity eventSubscription)  | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
CompensationUtil.throwCompensationEvent(List<EventSubscriptionEntity> eventSubscriptions,
                      ActivityExecution execution,
                      boolean async)
we create a separate execution for each compensation handler invocation. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
EventSubscriptionEntity | 
EventSubscriptionDeclaration.createSubscriptionForExecution(ExecutionEntity execution)
Creates and inserts a subscription entity depending on the message type of this declaration. 
 | 
EventSubscriptionEntity | 
EventSubscriptionDeclaration.createSubscriptionForStartEvent(ProcessDefinitionEntity processDefinition)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
EventSubscriptionDeclaration.updateSubscription(EventSubscriptionEntity eventSubscription)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected 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 Type | Method and Description | 
|---|---|
void | 
CommandLogger.couldNotFindProcessDefinitionForEventSubscription(EventSubscriptionEntity messageEventSubscription,
                                                 String processDefinitionId)  | 
void | 
CommandLogger.debugIgnoringEventSubscription(EventSubscriptionEntity eventSubscription,
                              String processDefinitionId)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected 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)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CompensationEventHandler.handleEvent(EventSubscriptionEntity eventSubscription,
           Object payload,
           Object localPayload,
           String businessKey,
           CommandContext commandContext)  | 
void | 
EventHandler.handleEvent(EventSubscriptionEntity eventSubscription,
           Object payload,
           Object localPayload,
           String businessKey,
           CommandContext commandContext)  | 
void | 
ConditionalEventHandler.handleEvent(EventSubscriptionEntity eventSubscription,
           Object payload,
           Object localPayload,
           String businessKey,
           CommandContext commandContext)  | 
void | 
EventHandlerImpl.handleEvent(EventSubscriptionEntity eventSubscription,
           Object payload,
           Object localPayload,
           String businessKey,
           CommandContext commandContext)  | 
void | 
SignalEventHandler.handleEvent(EventSubscriptionEntity eventSubscription,
           Object payload,
           Object payloadLocal,
           String businessKey,
           CommandContext commandContext)  | 
void | 
EventHandlerImpl.handleIntermediateEvent(EventSubscriptionEntity eventSubscription,
                       Object payload,
                       Object localPayload,
                       CommandContext commandContext)  | 
protected void | 
SignalEventHandler.handleStartEvent(EventSubscriptionEntity eventSubscription,
                Map<String,Object> payload,
                String businessKey,
                CommandContext commandContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
static EventSubscriptionJobDeclaration | 
EventSubscriptionJobDeclaration.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)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected EventSubscriptionEntity | 
MigratingCompensationEventSubscriptionInstance.eventSubscription  | 
protected EventSubscriptionEntity | 
MigratingEventSubscriptionInstance.eventSubscriptionEntity  | 
| Modifier and Type | Method and Description | 
|---|---|
MigratingCompensationEventSubscriptionInstance | 
MigratingProcessInstance.addCompensationSubscriptionInstance(MigrationInstruction eventSubscriptionInstruction,
                                   EventSubscriptionEntity eventSubscription,
                                   ScopeImpl sourceScope,
                                   ScopeImpl targetScope)  | 
MigratingEventScopeInstance | 
MigratingProcessInstance.addEventScopeInstance(MigrationInstruction migrationInstruction,
                     ExecutionEntity eventScopeExecution,
                     ScopeImpl sourceScope,
                     ScopeImpl targetScope,
                     MigrationInstruction eventSubscriptionInstruction,
                     EventSubscriptionEntity eventSubscription,
                     ScopeImpl eventSubscriptionSourceScope,
                     ScopeImpl eventSubscriptionTargetScope)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected MigratingInstanceParseHandler<EventSubscriptionEntity> | 
MigratingInstanceParser.compensationInstanceHandler  | 
protected MigratingDependentInstanceParseHandler<MigratingActivityInstance,List<EventSubscriptionEntity>> | 
MigratingInstanceParser.dependentEventSubscriptionHandler  | 
protected Collection<EventSubscriptionEntity> | 
MigratingInstanceParseContext.eventSubscriptions  | 
| Modifier and Type | Method and Description | 
|---|---|
protected List<EventSubscriptionEntity> | 
ActivityInstanceHandler.collectActivityInstanceEventSubscriptions(MigratingActivityInstance migratingInstance)  | 
protected static List<EventSubscriptionEntity> | 
CompensationEventSubscriptionWalker.collectCompensationEventSubscriptions(Collection<MigratingActivityInstance> activityInstances)  | 
protected List<EventSubscriptionEntity> | 
MigratingInstanceParser.fetchEventSubscriptions(CommandContext commandContext,
                       String processInstanceId)  | 
MigratingDependentInstanceParseHandler<MigratingActivityInstance,List<EventSubscriptionEntity>> | 
MigratingInstanceParser.getDependentEventSubscriptionHandler()  | 
protected Collection<EventSubscriptionEntity> | 
CompensationEventSubscriptionWalker.nextElements()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
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 Type | Method and Description | 
|---|---|
MigratingInstanceParseContext | 
MigratingInstanceParseContext.eventSubscriptions(Collection<EventSubscriptionEntity> eventSubscriptions)  | 
void | 
EventSubscriptionInstanceHandler.handle(MigratingInstanceParseContext parseContext,
      MigratingActivityInstance owningInstance,
      List<EventSubscriptionEntity> elements)  | 
void | 
MigratingInstanceParseContext.handleDependentEventSubscriptions(MigratingActivityInstance migratingInstance,
                                 List<EventSubscriptionEntity> eventSubscriptions)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected List<EventSubscriptionEntity> | 
EventSubscriptionManager.createdSignalSubscriptions
keep track of subscriptions created in the current command 
 | 
protected List<EventSubscriptionEntity> | 
ExecutionEntity.eventSubscriptions  | 
| Modifier and Type | Method and Description | 
|---|---|
static EventSubscriptionEntity | 
EventSubscriptionEntity.createAndInsert(ExecutionEntity executionEntity,
               EventType eventType,
               ActivityImpl activity)  | 
static EventSubscriptionEntity | 
EventSubscriptionEntity.createAndInsert(ExecutionEntity executionEntity,
               EventType eventType,
               ActivityImpl activity,
               String configuration)  | 
EventSubscriptionEntity | 
EventSubscriptionManager.findEventSubscriptionById(String id)  | 
EventSubscriptionEntity | 
EventSubscriptionManager.findMessageStartEventSubscriptionByNameAndTenantId(String messageName,
                                                  String tenantId)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
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)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ExecutionEntity.restoreProcessInstance(Collection<ExecutionEntity> executions,
                      Collection<EventSubscriptionEntity> eventSubscriptions,
                      Collection<VariableInstanceEntity> variables,
                      Collection<TaskEntity> tasks,
                      Collection<JobEntity> jobs,
                      Collection<IncidentEntity> incidents,
                      Collection<ExternalTaskEntity> externalTasks)
Restores a complete process instance tree including referenced entities. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected static boolean | 
LegacyBehavior.areEqualEventSubscriptions(EventSubscriptionEntity subscription1,
                          EventSubscriptionEntity subscription2)
Checks if the parameters are the same apart from the execution id 
 | 
static void | 
LegacyBehavior.removeLegacySubscriptionOnParent(ExecutionEntity execution,
                                EventSubscriptionEntity eventSubscription)
Required for migrating active sequential MI receive tasks. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected List<EventSubscriptionEntity> | 
DefaultConditionHandler.findConditionalStartEventSubscriptions(CommandContext commandContext,
                                      ConditionSet conditionSet)  | 
protected List<EventSubscriptionEntity> | 
DefaultCorrelationHandler.findMessageStartEventSubscriptions(CommandContext commandContext,
                                  String messageName,
                                  CorrelationSet correlationSet)  | 
Copyright © 2019. All rights reserved.