Package com.evolveum.midpoint.model.impl.sync.tasks.recon

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

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 out
ObjectQuery	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 class AbstractTaskExecution<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.

Overrides:

initialize in class AbstractTaskExecution<ReconciliationTaskHandler,ReconciliationTaskExecution>

Throws:

TaskException

CommunicationException

SchemaException

ObjectNotFoundException

SecurityViolationException

ConfigurationException

ExpressionEvaluationException

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 class AbstractTaskExecution<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)

Throws:

SchemaException

ObjectNotFoundException

SecurityViolationException

CommunicationException

ConfigurationException

ExpressionEvaluationException

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

Throws:

SchemaException

ObjectNotFoundException

SecurityViolationException

CommunicationException

ConfigurationException

ExpressionEvaluationException

getResource

public PrismObject<ResourceType> getResource()

getTargetInfo

public SyncTaskHelper.TargetInfo getTargetInfo()

getObjectsFilter

public SynchronizationObjectsFilterImpl getObjectsFilter()