Package com.evolveum.midpoint.task.api

Interface WorkBucketAwareTaskHandler

All Superinterfaces:

TaskHandler

All Known Implementing Classes:

AbstractModelTaskHandler, AbstractScannerTaskHandler, AbstractTaskHandler, AsyncUpdateTaskHandler, DeleteNotUpdatedShadowTaskHandler, ExecuteChangesTaskHandler, FocusValidityScannerTaskHandler, ImportFromResourceTaskHandler, IterativeScriptExecutionTaskHandler, LiveSyncTaskHandler, ObjectIntegrityCheckTaskHandler, RecomputeTaskHandler, ReconciliationTaskHandler, ReindexTaskHandler, ShadowIntegrityCheckTaskHandler, ShadowRefreshTaskHandler, SimpleIterativeTaskHandler, TriggerScannerTaskHandler

public interface WorkBucketAwareTaskHandler
extends TaskHandler

Task handler that supports bucketed tasks. Its `run` method provides bucket-related parameters that allow the implementation to (typically) narrow the query according to the current bucket. Also, the run result is enhanced with bucket-related properties.

Method Summary

Modifier and Type	Method	Description
default TaskWorkBucketProcessingResult	onNoMoreBuckets(RunningTask task, TaskWorkBucketProcessingResult previousRunResult, OperationResult result)
default TaskRunResult	run(RunningTask task, TaskPartitionDefinitionType partitionDefinition)
TaskWorkBucketProcessingResult	run(RunningTask task, WorkBucketType workBucket, TaskPartitionDefinitionType partitionDefinition, TaskWorkBucketProcessingResult previousRunResult)

Methods inherited from interface com.evolveum.midpoint.task.api.TaskHandler

getArchetypeOid, getCategoryName, getCategoryNames, getDefaultChannel, getStatisticsCollectionStrategy, heartbeat, refreshStatus, run

Method Detail

run

default TaskRunResult run(RunningTask task,
                          TaskPartitionDefinitionType partitionDefinition)

Specified by:

run in interface TaskHandler

run

TaskWorkBucketProcessingResult run(RunningTask task,
                                   WorkBucketType workBucket,
                                   TaskPartitionDefinitionType partitionDefinition,
                                   TaskWorkBucketProcessingResult previousRunResult)

onNoMoreBuckets

default TaskWorkBucketProcessingResult onNoMoreBuckets(RunningTask task,
                                                       TaskWorkBucketProcessingResult previousRunResult,
                                                       OperationResult result)