Package com.evolveum.midpoint.repo.common.task

Class ItemProcessingRequest<I>

java.lang.Object

com.evolveum.midpoint.repo.common.task.ItemProcessingRequest<I>

All Implemented Interfaces:

AcknowledgementSink

Direct Known Subclasses:

ObjectProcessingRequest, SyncItemProcessingRequest

public abstract class ItemProcessingRequest<I>
extends Object
implements AcknowledgementSink

Holds an item that is scheduled for processing.

Besides the item itself it provides so called correlation value that is used to correctly order requests that relate to the same midPoint or resource object - for example, two async changes related to a given account.

Field Summary

Fields

Modifier and Type	Field	Description
protected @NotNull String	identifier	Unique identifier of this request.
protected I	item

Constructor Summary

Constructors

Constructor	Description
ItemProcessingRequest(I item, @NotNull AbstractIterativeItemProcessor<I,?,?,?,?> itemProcessor)

Method Summary

Modifier and Type	Method	Description
protected OperationExecutionRecorderForTasks.Target	createRecordingTargetForObject(PrismObject<? extends ObjectType> object)
String	getIdentifier()
I	getItem()
abstract @Nullable String	getItemOid()	OID of the object connected to the item being processed (usually the object itself or related shadow).
abstract @NotNull IterationItemInformation	getIterationItemInformation()
abstract String	getObjectOidToRecordRetryTrigger()
abstract OperationExecutionRecorderForTasks.Target	getOperationExecutionRecordingTarget()
protected PrismContext	getPrismContext()
protected @NotNull String	getRootTaskOid()
abstract @Nullable SynchronizationSituationType	getSynchronizationSituationOnProcessingStart()	TODO reconsider
protected @NotNull QName	getType(PrismObject<?> object)
boolean	process(RunningTask workerTask, OperationResult result)

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.schema.AcknowledgementSink

acknowledge

Field Detail

item

@NotNull
protected final I item

identifier

@Experimental
@NotNull
protected final @NotNull String identifier

Unique identifier of this request. Not to be confused with requestIdentifier used for auditing purposes! Most probably it will be replaced by something different.

Constructor Detail

ItemProcessingRequest

public ItemProcessingRequest(@NotNull
                             I item,
                             @NotNull
                             @NotNull AbstractIterativeItemProcessor<I,?,?,?,?> itemProcessor)

Method Detail

getItem

@NotNull
public I getItem()

getOperationExecutionRecordingTarget

public abstract OperationExecutionRecorderForTasks.Target getOperationExecutionRecordingTarget()

Returns:

Object to which we will write an operation execution record (plus auxiliary information).

createRecordingTargetForObject

@NotNull
protected OperationExecutionRecorderForTasks.Target createRecordingTargetForObject(PrismObject<? extends ObjectType> object)

getObjectOidToRecordRetryTrigger

public abstract String getObjectOidToRecordRetryTrigger()

Returns:

OID of object to which we put a trigger causing operation retry (if known)

getIterationItemInformation

@NotNull
public abstract @NotNull IterationItemInformation getIterationItemInformation()

process

public boolean process(RunningTask workerTask,
                       OperationResult result)

getPrismContext

protected PrismContext getPrismContext()

getRootTaskOid

@NotNull
protected @NotNull String getRootTaskOid()

getType

@NotNull
protected @NotNull QName getType(PrismObject<?> object)

getItemOid

@Nullable
public abstract @Nullable String getItemOid()

OID of the object connected to the item being processed (usually the object itself or related shadow). TODO reconsider

getSynchronizationSituationOnProcessingStart

@Nullable
public abstract @Nullable SynchronizationSituationType getSynchronizationSituationOnProcessingStart()

TODO reconsider

getIdentifier

public String getIdentifier()