public class CompensationUtil extends Object
Modifier and Type | Field and Description |
---|---|
static String |
SIGNAL_COMPENSATION_DONE
name of the signal that is thrown when a compensation handler completed
|
Constructor and Description |
---|
CompensationUtil() |
Modifier and Type | Method and Description |
---|---|
static List<EventSubscriptionEntity> |
collectCompensateEventSubscriptionsForActivity(ActivityExecution execution,
String activityRef)
Collect all compensate event subscriptions for activity on the scope of
given execution.
|
static List<EventSubscriptionEntity> |
collectCompensateEventSubscriptionsForScope(ActivityExecution execution)
Collect all compensate event subscriptions for scope of given execution.
|
static void |
createEventScopeExecution(ExecutionEntity execution)
creates an event scope for the given execution:
create a new event scope execution under the parent of the given execution
and move all event subscriptions to that execution.
|
static ExecutionEntity |
getCompensatingExecution(EventSubscriptionEntity eventSubscription) |
protected static ActivityImpl |
getEventScopeCompensationHandler(ExecutionEntity execution)
In the context when an event scope execution is created (i.e.
|
protected static boolean |
hasCompensationEventSubprocess(ActivityImpl activity) |
static void |
throwCompensationEvent(List<EventSubscriptionEntity> eventSubscriptions,
ActivityExecution execution,
boolean async)
we create a separate execution for each compensation handler invocation.
|
public static final String SIGNAL_COMPENSATION_DONE
public static void throwCompensationEvent(List<EventSubscriptionEntity> eventSubscriptions, ActivityExecution execution, boolean async)
public static void createEventScopeExecution(ExecutionEntity execution)
protected static boolean hasCompensationEventSubprocess(ActivityImpl activity)
protected static ActivityImpl getEventScopeCompensationHandler(ExecutionEntity execution)
public static List<EventSubscriptionEntity> collectCompensateEventSubscriptionsForScope(ActivityExecution execution)
public static List<EventSubscriptionEntity> collectCompensateEventSubscriptionsForActivity(ActivityExecution execution, String activityRef)
public static ExecutionEntity getCompensatingExecution(EventSubscriptionEntity eventSubscription)
Copyright © 2021. All rights reserved.