Class ReconciliationTaskExecution
- java.lang.Object
-
- com.evolveum.midpoint.repo.common.task.AbstractTaskExecution<ReconciliationTaskHandler,ReconciliationTaskExecution>
-
- com.evolveum.midpoint.model.impl.sync.tasks.recon.ReconciliationTaskExecution
-
public class ReconciliationTaskExecution extends AbstractTaskExecution<ReconciliationTaskHandler,ReconciliationTaskExecution>
Execution of a reconciliation task. Responsible for creation of task parts, as given by the context: all three of them, or only a specified one.
-
-
Field Summary
Fields Modifier and Type Field Description protected XMLGregorianCalendar
startTimestamp
-
Fields inherited from class com.evolveum.midpoint.repo.common.task.AbstractTaskExecution
localCoordinatorTask, partDefinition, taskHandler, workBucket
-
-
Constructor Summary
Constructors Constructor Description ReconciliationTaskExecution(ReconciliationTaskHandler taskHandler, RunningTask localCoordinatorTask, WorkBucketType workBucket, TaskPartitionDefinitionType partDefinition, TaskWorkBucketProcessingResult previousRunResult)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<AbstractSearchIterativeTaskPartExecution<?,?,?,?,?>>
createPartExecutions()
Creates executions for individual task parts.ObjectQuery
createShadowQuery(ObjectQuery initialQuery, OperationResult opResult)
Creates shadow query by AND-ing: - specified initial query - explicit object query from the task (with filters resolved) TODO consider factoring outObjectQuery
createShadowQuery(OperationResult opResult)
Creates shadow query by AND-ing: - universal resource/objectclass/kind/intent filter from the task - explicit object query from the task (with filters resolved)protected void
finish(OperationResult opResult, Throwable t)
Called right before the execution stops, even in the case of exceptions.ObjectClassComplexTypeDefinition
getObjectClassDefinition()
SynchronizationObjectsFilterImpl
getObjectsFilter()
PrismObject<ResourceType>
getResource()
String
getResourceOid()
@NotNull com.evolveum.midpoint.model.impl.sync.tasks.recon.ReconciliationTaskExecution.Stage
getStage()
SyncTaskHelper.TargetInfo
getTargetInfo()
protected void
initialize(OperationResult opResult)
Called right on the start of the task execution, even before parts are created.-
Methods inherited from class com.evolveum.midpoint.repo.common.task.AbstractTaskExecution
getCurrentRunResult, getErrorState, getPrismContext, getRootTaskOid, getTaskContainerRealValue, getTaskPropertyRealValue, heartbeat, isInternallyMultipart, run, setPermanentErrorEncountered
-
-
-
-
Field Detail
-
startTimestamp
protected final XMLGregorianCalendar startTimestamp
-
-
Constructor Detail
-
ReconciliationTaskExecution
public ReconciliationTaskExecution(ReconciliationTaskHandler taskHandler, RunningTask localCoordinatorTask, WorkBucketType workBucket, TaskPartitionDefinitionType partDefinition, TaskWorkBucketProcessingResult previousRunResult)
-
-
Method Detail
-
createPartExecutions
public List<AbstractSearchIterativeTaskPartExecution<?,?,?,?,?>> createPartExecutions()
Description copied from class:AbstractTaskExecution
Creates executions for individual task parts. Overridden for handlers that have more than one part and therefore cannot rely on class annotations.- Overrides:
createPartExecutions
in classAbstractTaskExecution<ReconciliationTaskHandler,ReconciliationTaskExecution>
-
initialize
protected void initialize(OperationResult opResult) throws TaskException, CommunicationException, SchemaException, ObjectNotFoundException, SecurityViolationException, ConfigurationException, ExpressionEvaluationException
Description copied from class:AbstractTaskExecution
Called right on the start of the task execution, even before parts are created. Used for things like ResourceType object resolution, and so on.
-
finish
protected void finish(OperationResult opResult, Throwable t) throws TaskException, SchemaException
Description copied from class:AbstractTaskExecution
Called right before the execution stops, even in the case of exceptions.- Overrides:
finish
in classAbstractTaskExecution<ReconciliationTaskHandler,ReconciliationTaskExecution>
- Throws:
TaskException
SchemaException
-
getStage
@NotNull public @NotNull com.evolveum.midpoint.model.impl.sync.tasks.recon.ReconciliationTaskExecution.Stage getStage()
-
getResourceOid
public String getResourceOid()
-
getObjectClassDefinition
public ObjectClassComplexTypeDefinition getObjectClassDefinition()
-
createShadowQuery
public ObjectQuery createShadowQuery(OperationResult opResult) throws SchemaException, ObjectNotFoundException, SecurityViolationException, CommunicationException, ConfigurationException, ExpressionEvaluationException
Creates shadow query by AND-ing: - universal resource/objectclass/kind/intent filter from the task - explicit object query from the task (with filters resolved)
-
createShadowQuery
public ObjectQuery createShadowQuery(ObjectQuery initialQuery, OperationResult opResult) throws SchemaException, ObjectNotFoundException, SecurityViolationException, CommunicationException, ConfigurationException, ExpressionEvaluationException
Creates shadow query by AND-ing: - specified initial query - explicit object query from the task (with filters resolved) TODO consider factoring out
-
getResource
public PrismObject<ResourceType> getResource()
-
getTargetInfo
public SyncTaskHelper.TargetInfo getTargetInfo()
-
getObjectsFilter
public SynchronizationObjectsFilterImpl getObjectsFilter()
-
-