Uses of Interface
com.evolveum.midpoint.task.api.RunningTask
Package
Description
Contains the activity framework: the code that supports execution of activities within tasks.
Classes that support execution (run) of activities.
Deals with items processing: buffering, fetching by workers, processing.
-
Uses of RunningTask in com.evolveum.midpoint.cases.api
Modifier and TypeMethodDescriptionvoid
CaseManager.cleanupCases
(@NotNull CleanupPolicyType closedCasesPolicy, @NotNull RunningTask task, @NotNull OperationResult opResult) Deletes obsolete cases, as specified in the policy. -
Uses of RunningTask in com.evolveum.midpoint.model.api.trigger
Modifier and TypeMethodDescription<O extends ObjectType>
Collection<TriggerType>MultipleTriggersHandler.handle
(@NotNull PrismObject<O> object, @NotNull Collection<TriggerType> triggers, @NotNull RunningTask task, @NotNull OperationResult result) Precondition: triggers have the same timestamp -
Uses of RunningTask in com.evolveum.midpoint.model.impl.cleanup
Modifier and TypeMethodDescriptionboolean
ShadowRefreshActivityHandler.MyActivityRun.processItem
(@NotNull ShadowType object, @NotNull ItemProcessingRequest<ShadowType> request, RunningTask workerTask, OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.integrity.shadows
Modifier and TypeMethodDescriptionboolean
ShadowIntegrityCheckActivityRun.processItem
(@NotNull ShadowType shadow, @NotNull ItemProcessingRequest<ShadowType> request, RunningTask workerTask, OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.sync.tasks.async
Modifier and TypeMethodDescriptionboolean
AsyncUpdateActivityRun.processItem
(@NotNull ItemProcessingRequest<AsyncUpdateEvent> request, @NotNull RunningTask workerTask, OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.sync.tasks.imp
Modifier and TypeMethodDescriptionboolean
AbstractImportActivityRun.processItem
(@NotNull ShadowType object, @NotNull ItemProcessingRequest<ShadowType> request, RunningTask workerTask, OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.sync.tasks.recon
Modifier and TypeMethodDescriptionboolean
ResourceObjectsReconciliationActivityRun.processItem
(@NotNull ShadowType object, @NotNull ItemProcessingRequest<ShadowType> request, RunningTask workerTask, OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.sync.tasks.sync
Modifier and TypeMethodDescriptionboolean
LiveSyncActivityRun.processItem
(@NotNull ItemProcessingRequest<LiveSyncEvent> request, @NotNull RunningTask workerTask, @NotNull OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.tasks
Modifier and TypeMethodDescription@NotNull SearchSpecification<?>
AdvancedActivityRunSupportImpl.createSearchSpecificationFromResourceObjectSetSpec
(@NotNull ResourceObjectSetSpecificationImpl objectSetSpecification, @NotNull RunningTask task, OperationResult result) AdvancedActivityRunSupportImpl.evaluateQueryExpressions
(@NotNull ObjectQuery query, ExpressionProfile expressionProfile, @NotNull RunningTask task, OperationResult result) boolean
ShadowCleanupActivityHandler.MyRun.processItem
(@NotNull ShadowType shadow, @NotNull ItemProcessingRequest<ShadowType> request, RunningTask workerTask, OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.tasks.cluster
Modifier and TypeMethodDescriptionboolean
AutoScalingActivityRun.processItem
(@NotNull TaskType task, @NotNull ItemProcessingRequest<TaskType> request, RunningTask workerTask, OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.tasks.scanner
Modifier and TypeMethodDescriptionboolean
FocusValidityScanPartialRun.processItem
(@NotNull FocusType object, @NotNull ItemProcessingRequest<FocusType> request, RunningTask workerTask, OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.tasks.sources
Modifier and TypeMethodDescriptionModelAuditItemSource.count
(@NotNull SearchSpecification<?> searchSpecification, @NotNull RunningTask task, @NotNull OperationResult result) ModelContainerableItemSource.count
(@NotNull SearchSpecification<?> searchSpecification, @NotNull RunningTask task, @NotNull OperationResult result) ModelObjectSource.count
(@NotNull SearchSpecification<?> searchSpecification, @NotNull RunningTask task, @NotNull OperationResult result) <C extends Containerable>
voidModelAuditItemSource.searchIterative
(@NotNull SearchSpecification<C> searchSpecification, @NotNull ContainerableResultHandler<C> handler, @NotNull RunningTask task, @NotNull OperationResult result) <C extends Containerable>
voidModelContainerableItemSource.searchIterative
(@NotNull SearchSpecification<C> searchSpecification, @NotNull ContainerableResultHandler<C> handler, @NotNull RunningTask task, @NotNull OperationResult result) <C extends Containerable>
voidModelObjectSource.searchIterative
(@NotNull SearchSpecification<C> searchSpecification, @NotNull ContainerableResultHandler<C> handler, @NotNull RunningTask task, @NotNull OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.model.impl.trigger
Modifier and TypeMethodDescription<O extends ObjectType>
voidCompletedTaskCleanupTriggerHandler.handle
(@NotNull PrismObject<O> object, @NotNull TriggerType trigger, @NotNull RunningTask task, @NotNull OperationResult result) <O extends ObjectType>
voidRecomputeTriggerHandler.handle
(@NotNull PrismObject<O> object, @NotNull TriggerType trigger, @NotNull RunningTask task, @NotNull OperationResult result) <O extends ObjectType>
voidShadowReconcileTriggerHandler.handle
(@NotNull PrismObject<O> object, @NotNull TriggerType trigger, @NotNull RunningTask task, @NotNull OperationResult result) <O extends ObjectType>
voidSingleTriggerHandler.handle
(@NotNull PrismObject<O> object, @NotNull TriggerType trigger, @NotNull RunningTask task, @NotNull OperationResult result) <O extends ObjectType>
voidUnlockTriggerHandler.handle
(@NotNull PrismObject<O> object, @NotNull TriggerType trigger, @NotNull RunningTask task, @NotNull OperationResult result) boolean
TriggerScanItemProcessor.processObject
(@NotNull ObjectType object, @NotNull RunningTask workerTask, @NotNull OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.notifications.api.events
Modifier and TypeMethodDescription@NotNull RunningTask
ActivityEvent.getRunningTask()
Task in context of which the activity will execute, executes, or was executed. -
Uses of RunningTask in com.evolveum.midpoint.repo.common.activity
Modifier and TypeMethodDescriptionvoid
PreRunnable.run
(@NotNull EmbeddedActivity<WD, AH> activity, @NotNull RunningTask runningTask, @NotNull OperationResult result) -
Uses of RunningTask in com.evolveum.midpoint.repo.common.activity.run
Modifier and TypeMethodDescription@NotNull SearchSpecification<?>
AdvancedActivityRunSupport.createSearchSpecificationFromResourceObjectSetSpec
(@NotNull ResourceObjectSetSpecificationImpl resourceObjectSetSpecification, @NotNull RunningTask task, OperationResult result) AdvancedActivityRunSupport.evaluateQueryExpressions
(@NotNull ObjectQuery query, ExpressionProfile expressionProfile, @NotNull RunningTask task, OperationResult result) Assuming that query has expressions.abstract boolean
IterativeActivityRun.processItem
(@NotNull ItemProcessingRequest<I> request, @NotNull RunningTask workerTask, OperationResult result) final boolean
SearchBasedActivityRun.processItem
(@NotNull ItemProcessingRequest<C> request, @NotNull RunningTask workerTask, OperationResult result) boolean
SearchBasedActivityRunSpecifics.processItem
(C item, @NotNull ItemProcessingRequest<C> request, RunningTask workerTask, OperationResult result) Processes given item that came as part of a request. -
Uses of RunningTask in com.evolveum.midpoint.repo.common.activity.run.processing
Modifier and TypeMethodDescriptionboolean
ItemProcessingRequest.process
(RunningTask workerTask, OperationResult result) boolean
ItemProcessor.processItem
(ItemProcessingRequest<I> request, RunningTask workerTask, OperationResult parentResult) Does the "pure" processing, free of any reporting, error handling, tracing, and similar issues. -
Uses of RunningTask in com.evolveum.midpoint.repo.common.activity.run.reports
Modifier and TypeMethodDescriptionvoid
InternalOperationsReport.add
(@NotNull ItemProcessingRequest<?> request, @NotNull WorkBucketType bucket, @NotNull OperationResult reportedResult, @NotNull RunningTask task, @NotNull OperationResult result) void
ConnIdOperationsReport.flush
(@NotNull RunningTask task, @NotNull OperationResult result) void
BucketsReport.recordBucketCompleted
(@NotNull BucketProcessingRecordType record, @NotNull RunningTask task, @NotNull OperationResult result) Writes a line about bucket that was just completed.void
ItemsReport.recordItemProcessed
(@NotNull ItemProcessingRecordType record, @NotNull RunningTask task, @NotNull OperationResult result) Records processing of an item to the report. -
Uses of RunningTask in com.evolveum.midpoint.repo.common.activity.run.sources
Modifier and TypeMethodDescriptionRepoAuditItemSource.count
(@NotNull SearchSpecification<?> searchSpecification, @NotNull RunningTask task, @NotNull OperationResult result) RepoObjectSource.count
(@NotNull SearchSpecification<?> searchSpecification, @NotNull RunningTask task, @NotNull OperationResult result) SearchableItemSource.count
(@NotNull SearchSpecification<?> searchSpecification, @NotNull RunningTask task, @NotNull OperationResult result) Counts items according to given search specification.<C extends Containerable>
voidRepoAuditItemSource.searchIterative
(@NotNull SearchSpecification<C> searchSpecification, @NotNull ContainerableResultHandler<C> handler, @NotNull RunningTask task, @NotNull OperationResult result) <C extends Containerable>
voidRepoObjectSource.searchIterative
(@NotNull SearchSpecification<C> searchSpecification, @NotNull ContainerableResultHandler<C> handler, @NotNull RunningTask task, @NotNull OperationResult result) <C extends Containerable>
voidSearchableItemSource.searchIterative
(@NotNull SearchSpecification<C> searchSpecification, @NotNull ContainerableResultHandler<C> handler, @NotNull RunningTask task, @NotNull OperationResult result) Searches for items according to given search specification. -
Uses of RunningTask in com.evolveum.midpoint.repo.common.activity.run.task
Modifier and TypeMethodDescription@NotNull RunningTask
ActivityBasedTaskRun.getRunningTask()
@NotNull RunningTask
TaskRun.getRunningTask()
Returns the task associated with this run.Modifier and TypeMethodDescriptionvoid
ActivityBasedTaskHandler.onTaskStalled
(@NotNull RunningTask task, long stalledSince, @NotNull OperationResult result) ActivityBasedTaskHandler.run
(@NotNull RunningTask localCoordinatorTask) Main entry point. -
Uses of RunningTask in com.evolveum.midpoint.repo.common.util
Modifier and TypeMethodDescriptionvoid
OperationExecutionRecorderForTasks.recordOperationExecution
(@NotNull OperationExecutionRecorderForTasks.Target target, @NotNull RunningTask task, @NotNull ActivityPath activityPath, @NotNull OperationResult resultToRecord, @NotNull OperationResult result) Writes an operation execution record. -
Uses of RunningTask in com.evolveum.midpoint.report.api
Modifier and TypeMethodDescriptionvoid
ReportManager.cleanupReports
(CleanupPolicyType cleanupPolicy, RunningTask task, OperationResult parentResult) todo comments [lazyman] todo how to return progress -
Uses of RunningTask in com.evolveum.midpoint.task.api
Modifier and TypeInterfaceDescriptioninterface
Running lightweight asynchronous task.Modifier and TypeMethodDescriptionTaskManager.createFakeRunningTask
(Task task) Use only for tests.RunningLightweightTask.getLightweightTaskParent()
Returns the in-memory version of the parent task.TaskManager.getLocallyRunningTaskByIdentifier
(String lightweightIdentifier) Returns locally-run task by identifier.Modifier and TypeMethodDescriptionvoid
TaskManager.cleanupNodes
(@NotNull DeadNodeCleanupPolicyType deadNodesPolicy, @NotNull Predicate<NodeType> selector, @NotNull RunningTask task, @NotNull OperationResult opResult) Deletes dead nodes, i.e.void
TaskManager.cleanupTasks
(@NotNull CleanupPolicyType closedTasksPolicy, @NotNull Predicate<TaskType> selector, @NotNull RunningTask task, @NotNull OperationResult opResult) Deletes obsolete tasks, as specified in the policy.default void
TaskHandler.onTaskStalled
(@NotNull RunningTask task, long stalledSince, @NotNull OperationResult result) Should update the state of the task when the task manager finds that the task is stalled, i.e.TaskHandler.run
(@NotNull RunningTask task) Executes a task handler.void
TaskManager.waitForTransientChildrenAndCloseThem
(RunningTask task, OperationResult result) Should be called only from the thread that created the children - to avoid race conditions.