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
-
-
Constructor Summary
Constructors Constructor Description ReconciliationTaskHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getArchetypeOid()
String
getCategoryName(Task task)
Returns a category name for a given task.ReconciliationTaskResultListener
getReconciliationTaskResultListener()
@NotNull 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
-
-
-
-
Method Detail
-
getReconciliationTaskResultListener
public ReconciliationTaskResultListener getReconciliationTaskResultListener()
-
setReconciliationTaskResultListener
public void setReconciliationTaskResultListener(ReconciliationTaskResultListener reconciliationTaskResultListener)
-
getStatisticsCollectionStrategy
@NotNull public @NotNull 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"
-
getArchetypeOid
public String getArchetypeOid()
- Specified by:
getArchetypeOid
in interfaceTaskHandler
- Returns:
- Archetype OID for tasks that are powered by this handler.
-
-