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

Class AsyncUpdateTaskHandler.PartExecution

java.lang.Object

com.evolveum.midpoint.repo.common.task.AbstractIterativeTaskPartExecution<AsyncUpdateEvent,AsyncUpdateTaskHandler,AsyncUpdateTaskHandler.TaskExecution,AsyncUpdateTaskHandler.PartExecution,AsyncUpdateTaskHandler.PartExecution.ItemProcessor>

com.evolveum.midpoint.model.impl.sync.tasks.AsyncUpdateTaskHandler.PartExecution

Enclosing class:

AsyncUpdateTaskHandler

public class AsyncUpdateTaskHandler.PartExecution
extends AbstractIterativeTaskPartExecution<AsyncUpdateEvent,AsyncUpdateTaskHandler,AsyncUpdateTaskHandler.TaskExecution,AsyncUpdateTaskHandler.PartExecution,AsyncUpdateTaskHandler.PartExecution.ItemProcessor>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	AsyncUpdateTaskHandler.PartExecution.ItemProcessor

Field Summary

Fields inherited from class com.evolveum.midpoint.repo.common.task.AbstractIterativeTaskPartExecution

bucketStatistics, coordinator, itemProcessor, localCoordinatorTask, logger, reportingOptions, runResult, taskExecution, taskHandler

Constructor Summary

Constructors

Constructor	Description
PartExecution(AsyncUpdateTaskHandler.TaskExecution taskExecution)

Method Summary

Modifier and Type	Method	Description
protected ErrorHandlingStrategyExecutor.Action	getDefaultErrorAction()
protected void	processItems(OperationResult opResult)	Starts the item source (e.g.
boolean	providesTracingAndDynamicProfiling()

Methods inherited from class com.evolveum.midpoint.repo.common.task.AbstractIterativeTaskPartExecution

createItemProcessor, ensureNoWorkerThreads, finish, getContextDescription, getExpectedParts, getLogger, getPartNumber, getPartStartTimestamp, getPartUri, getProcessShortName, getProcessShortNameCapitalized, getReportingOptions, getRootTask, getRootTaskOid, getStartTimeMillis, getTaskExecution, heartbeat, initialize, isMultithreaded, isSimulate, prepareItemSource, run, setContextDescription, setExpectedParts, setExpectedTotal, setPartNumber, setPartUri, setProcessShortNameCapitalized

Methods inherited from class java.lang.Object

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

Constructor Detail

PartExecution

public PartExecution(@NotNull
                     AsyncUpdateTaskHandler.TaskExecution taskExecution)

Method Detail

providesTracingAndDynamicProfiling

public boolean providesTracingAndDynamicProfiling()

Specified by:

providesTracingAndDynamicProfiling in class AbstractIterativeTaskPartExecution<AsyncUpdateEvent,AsyncUpdateTaskHandler,AsyncUpdateTaskHandler.TaskExecution,AsyncUpdateTaskHandler.PartExecution,AsyncUpdateTaskHandler.PartExecution.ItemProcessor>

Returns:

True if this task execution should periodically write traces, according to relevant task extension items. It is also used to drive dynamic profiling (which is going to be deprecated).

processItems

protected void processItems(OperationResult opResult)
                     throws CommunicationException,
                            ObjectNotFoundException,
                            SchemaException,
                            SecurityViolationException,
                            ConfigurationException,
                            ExpressionEvaluationException,
                            PolicyViolationException,
                            PreconditionViolationException

Description copied from class: AbstractIterativeTaskPartExecution

Starts the item source (e.g. searchObjectsIterative call or synchronize call) and begins processing items generated by it. Returns when the source finishes. For example: - for search-based tasks, this call returns immediately after the search is over ... TODO ok? - for live sync task, this returns after all changes were fetched and acknowledged, and the resulting token was written - for async update task, this returns also after all changes were fetched and acknowledged and confirmed to the source

Specified by:

processItems in class AbstractIterativeTaskPartExecution<AsyncUpdateEvent,AsyncUpdateTaskHandler,AsyncUpdateTaskHandler.TaskExecution,AsyncUpdateTaskHandler.PartExecution,AsyncUpdateTaskHandler.PartExecution.ItemProcessor>

Throws:

CommunicationException

ObjectNotFoundException

SchemaException

SecurityViolationException

ConfigurationException

ExpressionEvaluationException

PolicyViolationException

PreconditionViolationException

getDefaultErrorAction

@NotNull
protected ErrorHandlingStrategyExecutor.Action getDefaultErrorAction()

Specified by:

getDefaultErrorAction in class AbstractIterativeTaskPartExecution<AsyncUpdateEvent,AsyncUpdateTaskHandler,AsyncUpdateTaskHandler.TaskExecution,AsyncUpdateTaskHandler.PartExecution,AsyncUpdateTaskHandler.PartExecution.ItemProcessor>

Returns:

Default error action if no policy is specified or if no policy entry matches.