Package com.evolveum.midpoint.repo.common.activity

Class TaskActivityManager

java.lang.Object

com.evolveum.midpoint.repo.common.activity.TaskActivityManager

@Experimental
@Component
public class TaskActivityManager
extends Object

Provides common functionality related to activities (something like TaskManager does for tasks).

Constructor Summary

Constructors

Constructor	Description
TaskActivityManager()

Method Summary

Modifier and Type	Method	Description
@Nullable TaskAffectedObjectsType	computeAffectedObjects(@Nullable ActivityDefinitionType activityDefinitionBean, AbstractActivityWorkStateType state)	Computes affected objects for a given activity definition, either simple or composite.
void	deleteActivityStateAndWorkers(@NotNull String rootTaskOid, boolean deleteWorkers, long subtasksWaitTime, OperationResult parentResult)	TODO somehow unify with TaskStatePurger
@NotNull Activity<?,?>	getActivity(Task rootTask, ActivityPath activityPath)
@NotNull com.google.common.collect.Multimap<ActivityPath,OtherActivityState>	getAllActivityStates(String rootTaskOid, OperationResult result)	Returns all activity state beans in the task tree.
TreeNode<ActivityPerformanceInformation>	getPerformanceInformation(String rootTaskOid, OperationResult result)
ActivityProgressInformation	getProgressInformation(@NotNull String rootTaskOid, @NotNull ActivityProgressInformationBuilder.InformationSource source, @NotNull OperationResult result)
ActivityProgressInformation	getProgressInformationFromTaskTree(String rootTaskOid, OperationResult result)	Assumes that the whole task tree is loaded.
@NotNull Map<ActivityPath,WorkersReconciliationResultType>	reconcileWorkers(@NotNull String rootTaskOid, @NotNull OperationResult parentResult)	Note that we reconcile only workers for distributed activities that already have their state.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TaskActivityManager

public TaskActivityManager()

Method Details

getProgressInformationFromTaskTree

public ActivityProgressInformation getProgressInformationFromTaskTree(String rootTaskOid,
 OperationResult result)
                                                               throws SchemaException,
ObjectNotFoundException

Assumes that the whole task tree is loaded.

Throws:

SchemaException

ObjectNotFoundException

getProgressInformation

public ActivityProgressInformation getProgressInformation(@NotNull
 @NotNull String rootTaskOid,
 @NotNull
 @NotNull ActivityProgressInformationBuilder.InformationSource source,
 @NotNull
 @NotNull OperationResult result)
                                                   throws SchemaException,
ObjectNotFoundException

Throws:

SchemaException

ObjectNotFoundException

getPerformanceInformation

public TreeNode<ActivityPerformanceInformation> getPerformanceInformation(String rootTaskOid,
 OperationResult result)
                                                                   throws SchemaException,
ObjectNotFoundException

Throws:

SchemaException

ObjectNotFoundException

getActivity

@NotNull
public @NotNull Activity<?,?> getActivity(Task rootTask,
 ActivityPath activityPath)
                                   throws SchemaException,
ConfigurationException

Throws:

SchemaException

ConfigurationException

reconcileWorkers

@NotNull
public @NotNull Map<ActivityPath,WorkersReconciliationResultType> reconcileWorkers(@NotNull
 @NotNull String rootTaskOid,
 @NotNull
 @NotNull OperationResult parentResult)
                                                                            throws SchemaException,
ObjectNotFoundException

Note that we reconcile only workers for distributed activities that already have their state.

Throws:

SchemaException

ObjectNotFoundException

deleteActivityStateAndWorkers

public void deleteActivityStateAndWorkers(@NotNull
 @NotNull String rootTaskOid,
 boolean deleteWorkers,
 long subtasksWaitTime,
 OperationResult parentResult)
                                   throws SchemaException,
ObjectNotFoundException

TODO somehow unify with TaskStatePurger

Throws:

SchemaException

ObjectNotFoundException

computeAffectedObjects

@Nullable
public @Nullable TaskAffectedObjectsType computeAffectedObjects(@Nullable
 @Nullable ActivityDefinitionType activityDefinitionBean,
 AbstractActivityWorkStateType state)
                                                         throws SchemaException,
ConfigurationException

Computes affected objects for a given activity definition, either simple or composite.

Throws:

SchemaException

ConfigurationException

getAllActivityStates

@NotNull
public @NotNull com.google.common.collect.Multimap<ActivityPath,OtherActivityState> getAllActivityStates(String rootTaskOid,
 OperationResult result)
                                                                                                  throws SchemaException,
ObjectNotFoundException

Returns all activity state beans in the task tree. Note that for delegated activities, there are usually two states returned: one from the delegator task and one from the delegate task. In a similar way, for distributed activities, there is usually one state from the coordinator task and multiple states from the worker tasks.

Throws:

SchemaException

ObjectNotFoundException