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

Class SyncItemProcessingRequest<SE extends SynchronizationEvent>

java.lang.Object

com.evolveum.midpoint.repo.common.activity.run.processing.ItemProcessingRequest<SE>

com.evolveum.midpoint.model.impl.sync.tasks.SyncItemProcessingRequest<SE>

All Implemented Interfaces:

CorrelatableProcessingRequest, AcknowledgementSink, Comparable<SyncItemProcessingRequest<SE>>

public class SyncItemProcessingRequest<SE extends SynchronizationEvent>
extends ItemProcessingRequest<SE>
implements Comparable<SyncItemProcessingRequest<SE>>, CorrelatableProcessingRequest

TODO It is comparable on the sequence number.

Field Summary

Fields inherited from class com.evolveum.midpoint.repo.common.activity.run.processing.ItemProcessingRequest

identifier, item

Constructor Summary

Constructors

Constructor	Description
SyncItemProcessingRequest(SE item, IterativeActivityRun<SE,?,?,?> activityRun)

Method Summary

Modifier and Type	Method	Description
void	acknowledge(boolean release, OperationResult result)	Informs the receiver that a particular item was processed (successfully or not).
int	compareTo(@NotNull SyncItemProcessingRequest<SE> o)
Object	getCorrelationValue()
@Nullable String	getItemOid()	OID of the object connected to the item being processed (usually the object itself or related shadow).
@NotNull IterationItemInformation	getIterationItemInformation()
String	getObjectOidToRecordRetryTrigger()
OperationExecutionRecorderForTasks.Target	getOperationExecutionRecordingTarget()
@Nullable SynchronizationSituationType	getSynchronizationSituationOnProcessingStart()	TODO reconsider
String	toString()

Methods inherited from class com.evolveum.midpoint.repo.common.activity.run.processing.ItemProcessingRequest

createRecordingTargetForObject, getIdentifier, getItem, getRootTaskOid, getSequentialNumber, getType, getType, process

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncItemProcessingRequest

public SyncItemProcessingRequest(SE item,
                                 IterativeActivityRun<SE,?,?,?> activityRun)

Method Detail

getCorrelationValue

public Object getCorrelationValue()

Specified by:

getCorrelationValue in interface CorrelatableProcessingRequest

Returns:

The value against which we match other requests to be aligned with this one.

getOperationExecutionRecordingTarget

public OperationExecutionRecorderForTasks.Target getOperationExecutionRecordingTarget()

Specified by:

getOperationExecutionRecordingTarget in class ItemProcessingRequest<SE extends SynchronizationEvent>

Returns:

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

getObjectOidToRecordRetryTrigger

public String getObjectOidToRecordRetryTrigger()

Specified by:

getObjectOidToRecordRetryTrigger in class ItemProcessingRequest<SE extends SynchronizationEvent>

Returns:

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

getIterationItemInformation

@NotNull
public @NotNull IterationItemInformation getIterationItemInformation()

Specified by:

getIterationItemInformation in class ItemProcessingRequest<SE extends SynchronizationEvent>

acknowledge

public void acknowledge(boolean release,
                        OperationResult result)

Description copied from interface: AcknowledgementSink

Informs the receiver that a particular item was processed (successfully or not).

Specified by:

acknowledge in interface AcknowledgementSink

Parameters:

release - If true, the item can be forgotten. If false, we want to receive that item again, presumably to be reprocessed later.

result - Operation result in context of which the acknowledgement should take place. It is useful if the acknowledgement itself can take considerable time, e.g. when it involves a communication with an external party.

compareTo

public int compareTo(@NotNull
                     @NotNull SyncItemProcessingRequest<SE> o)

Specified by:

compareTo in interface Comparable<SE extends SynchronizationEvent>

getItemOid

@Nullable
public @Nullable String getItemOid()

Description copied from class: ItemProcessingRequest

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

Specified by:

getItemOid in class ItemProcessingRequest<SE extends SynchronizationEvent>

getSynchronizationSituationOnProcessingStart

@Nullable
public @Nullable SynchronizationSituationType getSynchronizationSituationOnProcessingStart()

Description copied from class: ItemProcessingRequest

TODO reconsider

Specified by:

getSynchronizationSituationOnProcessingStart in class ItemProcessingRequest<SE extends SynchronizationEvent>

toString

public String toString()

Overrides:

toString in class ItemProcessingRequest<SE extends SynchronizationEvent>