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 © 2019. All rights reserved.