Class ReconciliationTaskHandler
- java.lang.Object
-
- com.evolveum.midpoint.model.impl.sync.ReconciliationTaskHandler
-
- All Implemented Interfaces:
TaskHandler
,WorkBucketAwareTaskHandler
@Component public class ReconciliationTaskHandler extends Object implements WorkBucketAwareTaskHandler
The task handler for reconciliation. This handler takes care of executing reconciliation "runs". It means that the handler "run" method will be as scheduled (every few days). The responsibility is to iterate over accounts and compare the real state with the assumed IDM state.- Author:
- Radovan Semancik
-
-
Field Summary
Fields Modifier and Type Field Description static String
DRY_RUN_URI
static String
EXECUTE_URI
static String
SIMULATE_URI
-
Constructor Summary
Constructors Constructor Description ReconciliationTaskHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getCategoryName(Task task)
Returns a category name for a given task.ReconciliationTaskResultListener
getReconciliationTaskResultListener()
StatisticsCollectionStrategy
getStatisticsCollectionStrategy()
Long
heartbeat(Task task)
void
launch(ResourceType resource, QName objectclass, Task task, OperationResult parentResult)
Launch an import.void
refreshStatus(Task task)
TaskWorkBucketProcessingResult
run(RunningTask localCoordinatorTask, WorkBucketType workBucket, TaskPartitionDefinitionType partitionDefinition, TaskWorkBucketProcessingResult previousRunResult)
void
setReconciliationTaskResultListener(ReconciliationTaskResultListener reconciliationTaskResultListener)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.evolveum.midpoint.task.api.TaskHandler
getCategoryNames
-
Methods inherited from interface com.evolveum.midpoint.task.api.WorkBucketAwareTaskHandler
getObjectQueryTypeFromTaskExtension, onNoMoreBuckets, run, run
-
-
-
-
Field Detail
-
DRY_RUN_URI
public static final String DRY_RUN_URI
- See Also:
- Constant Field Values
-
SIMULATE_URI
public static final String SIMULATE_URI
- See Also:
- Constant Field Values
-
EXECUTE_URI
public static final String EXECUTE_URI
- See Also:
- Constant Field Values
-
-
Method Detail
-
getReconciliationTaskResultListener
public ReconciliationTaskResultListener getReconciliationTaskResultListener()
-
setReconciliationTaskResultListener
public void setReconciliationTaskResultListener(ReconciliationTaskResultListener reconciliationTaskResultListener)
-
getStatisticsCollectionStrategy
@NotNull public StatisticsCollectionStrategy getStatisticsCollectionStrategy()
- Specified by:
getStatisticsCollectionStrategy
in interfaceTaskHandler
-
run
public TaskWorkBucketProcessingResult run(RunningTask localCoordinatorTask, WorkBucketType workBucket, TaskPartitionDefinitionType partitionDefinition, TaskWorkBucketProcessingResult previousRunResult)
- Specified by:
run
in interfaceWorkBucketAwareTaskHandler
-
launch
public void launch(ResourceType resource, QName objectclass, Task task, OperationResult parentResult)
Launch an import. Calling this method will start import in a new thread, possibly on a different node.
-
heartbeat
public Long heartbeat(Task task)
- Specified by:
heartbeat
in interfaceTaskHandler
-
refreshStatus
public void refreshStatus(Task task)
- Specified by:
refreshStatus
in interfaceTaskHandler
-
getCategoryName
public String getCategoryName(Task task)
Description copied from interface:TaskHandler
Returns a category name for a given task. In most cases, the name would be independent of concrete task.- Specified by:
getCategoryName
in interfaceTaskHandler
- Parameters:
task
- a task, whose category is to be determined; if getCategoryNames() returns null, this method has to accept null value as this parameter, and return the (one) category name that it gives to all tasks- Returns:
- a user-understandable name, like "LiveSync" or "Workflow"
-
-