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 |
IntermediateConditionalEventBehavior.leaveOnSatisfiedCondition(EventSubscriptionEntity eventSubscription,
VariableEvent variableEvent) |
void |
EventSubProcessStartConditionalEventActivityBehavior.leaveOnSatisfiedCondition(EventSubscriptionEntity eventSubscription,
VariableEvent variableEvent) |
void |
ConditionalEventBehavior.leaveOnSatisfiedCondition(EventSubscriptionEntity eventSubscription,
VariableEvent variableEvent)
Checks the condition, on satisfaction the activity is leaved.
|
void |
BoundaryConditionalEventActivityBehavior.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 |
SignalEventHandler.handleEvent(EventSubscriptionEntity eventSubscription,
Object payload,
CommandContext commandContext) |
void |
EventHandlerImpl.handleEvent(EventSubscriptionEntity eventSubscription,
Object payload,
CommandContext commandContext) |
void |
EventHandler.handleEvent(EventSubscriptionEntity eventSubscription,
Object payload,
CommandContext commandContext) |
void |
ConditionalEventHandler.handleEvent(EventSubscriptionEntity eventSubscription,
Object payload,
CommandContext commandContext) |
void |
CompensationEventHandler.handleEvent(EventSubscriptionEntity eventSubscription,
Object payload,
CommandContext commandContext) |
void |
EventHandlerImpl.handleIntermediateEvent(EventSubscriptionEntity eventSubscription,
Object payload,
CommandContext commandContext) |
protected void |
SignalEventHandler.handleStartEvent(EventSubscriptionEntity eventSubscription,
Object payload,
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> |
DefaultCorrelationHandler.findMessageStartEventSubscriptions(CommandContext commandContext,
String messageName,
CorrelationSet correlationSet) |
Copyright © 2017. All rights reserved.