Package com.evolveum.midpoint.repo.common.activity.run.state

Class CurrentActivityState<WS extends AbstractActivityWorkStateType>

java.lang.Object

com.evolveum.midpoint.repo.common.activity.run.state.ActivityState

com.evolveum.midpoint.repo.common.activity.run.state.CurrentActivityState<WS>

Type Parameters:

WS - Work (business) state of the activity.

All Implemented Interfaces:

DebugDumpable

public class CurrentActivityState<WS extends AbstractActivityWorkStateType>
extends ActivityState

Activity state for the current activity run. Provides the full functionality, including creation of the work state and maintenance of live progress and statistics.

Field Summary

Fields inherited from class com.evolveum.midpoint.repo.common.activity.run.state.ActivityState

beans, stateItemPath

Fields inherited from interface com.evolveum.midpoint.util.DebugDumpable

INDENT_STRING

Constructor Summary

Constructors

Constructor	Description
CurrentActivityState(@NotNull AbstractActivityRun<?,?,WS> activityRun)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the activity state.
protected void	debugDumpExtra(StringBuilder sb, int indent)
@NotNull ActivityPath	getActivityPath()
@NotNull AbstractActivityRun<?,?,WS>	getActivityRun()
@NotNull BucketsReport	getBucketsReport()
@NotNull ConnIdOperationsReport	getConnIdOperationsReport()
protected @NotNull String	getEnhancedClassName()
@NotNull InternalOperationsReport	getInternalOperationsReport()
ItemPath	getItemPath()
@NotNull ItemsReport	getItemsReport()
@NotNull ActivityItemProcessingStatistics	getLiveItemProcessingStatistics()
@NotNull ActivityProgress	getLiveProgress()
@NotNull ActivityStatistics	getLiveStatistics()
ActivityBucketManagementStatisticsType	getStoredBucketManagementStatistics()
ActivityItemProcessingStatisticsType	getStoredItemProcessingStatistics()
ActivityProgressType	getStoredProgress()
protected @NotNull Task	getTask()
@NotNull ComplexTypeDefinition	getWorkStateComplexTypeDefinition()
void	initialize(OperationResult result)	Puts the activity state into operation: 1.
void	markComplete(OperationResultStatus resultStatus, Long endTimestamp)
void	recordRealizationStart(long startTimestamp)
void	recordRealizationStart(XMLGregorianCalendar startTimestamp)
void	recordRunEnd(Long endTimestamp)
void	recordRunStart(Long startTimestamp)
void	setRealizationState(ActivityRealizationStateType value)
void	setResultStatus(@NotNull OperationResultStatus status)
void	setRunEndTimestamp(Long value)
void	updateProgressAndStatisticsNoCommit()
void	updateProgressNoCommit()

Methods inherited from class com.evolveum.midpoint.repo.common.activity.run.state.ActivityState

addDeleteItemRealValues, debugDump, flushPendingTaskModifications, flushPendingTaskModificationsChecked, getActivityStateDownwards, getActivityStateUpwards, getBucketingRole, getCurrentActivityStateInParentTask, getParentActivityState, getPropertyRealValue, getRealizationStartTimestamp, getRealizationState, getResultStatus, getWorkStateItemRealValueClone, getWorkStatePropertyRealValue, getWorkStateReferenceRealValue, getWorkStateReferenceRealValues, incrementCounters, isComplete, isScavenger, isWorker, setItemRealValues, setItemRealValuesCollection, setWorkStateItemRealValues, setWorkStateItemRealValues, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.evolveum.midpoint.util.DebugDumpable

debugDump, debugDumpLazily, debugDumpLazily

Constructor Detail

CurrentActivityState

public CurrentActivityState(@NotNull
                            @NotNull AbstractActivityRun<?,?,WS> activityRun)

Method Detail

initialize

public void initialize(OperationResult result)
                throws ActivityRunException

Puts the activity state into operation: 1. finds/creates activity and optionally also work state container values; 2. initializes live structures - currently that means progress and statistics objects. This method may or may not be called just before the real run. For example, there can be a need to initialize the state of all child activities before starting their real run.

Throws:

ActivityRunException

close

public void close()

Closes the activity state. Currently this means closing the reports.

recordRunStart

public void recordRunStart(Long startTimestamp)
                    throws ActivityRunException

Throws:

ActivityRunException

recordRunEnd

public void recordRunEnd(Long endTimestamp)
                  throws ActivityRunException

Throws:

ActivityRunException

recordRealizationStart

public void recordRealizationStart(long startTimestamp)
                            throws ActivityRunException

Throws:

ActivityRunException

recordRealizationStart

public void recordRealizationStart(XMLGregorianCalendar startTimestamp)
                            throws ActivityRunException

Throws:

ActivityRunException

markComplete

public void markComplete(OperationResultStatus resultStatus,
                         Long endTimestamp)
                  throws ActivityRunException

Throws:

ActivityRunException

setRealizationState

public void setRealizationState(ActivityRealizationStateType value)
                         throws ActivityRunException

Throws:

ActivityRunException

setRunEndTimestamp

public void setRunEndTimestamp(Long value)
                        throws ActivityRunException

Throws:

ActivityRunException

setResultStatus

public void setResultStatus(@NotNull
                            @NotNull OperationResultStatus status)
                     throws ActivityRunException

Throws:

ActivityRunException

getActivityPath

@NotNull
public @NotNull ActivityPath getActivityPath()

Specified by:

getActivityPath in class ActivityState

getActivityRun

@NotNull
public @NotNull AbstractActivityRun<?,?,WS> getActivityRun()

getItemPath

public ItemPath getItemPath()

getTask

@NotNull
protected @NotNull Task getTask()

Specified by:

getTask in class ActivityState

getWorkStateComplexTypeDefinition

@NotNull
public @NotNull ComplexTypeDefinition getWorkStateComplexTypeDefinition()

Specified by:

getWorkStateComplexTypeDefinition in class ActivityState

getLiveProgress

@NotNull
public @NotNull ActivityProgress getLiveProgress()

getStoredProgress

public ActivityProgressType getStoredProgress()

getLiveStatistics

@NotNull
public @NotNull ActivityStatistics getLiveStatistics()

getLiveItemProcessingStatistics

@NotNull
public @NotNull ActivityItemProcessingStatistics getLiveItemProcessingStatistics()

getStoredItemProcessingStatistics

public ActivityItemProcessingStatisticsType getStoredItemProcessingStatistics()

getStoredBucketManagementStatistics

public ActivityBucketManagementStatisticsType getStoredBucketManagementStatistics()

updateProgressAndStatisticsNoCommit

public void updateProgressAndStatisticsNoCommit()
                                         throws ActivityRunException

Throws:

ActivityRunException

updateProgressNoCommit

public void updateProgressNoCommit()
                            throws ActivityRunException

Throws:

ActivityRunException

getBucketsReport

@NotNull
public @NotNull BucketsReport getBucketsReport()

getItemsReport

@NotNull
public @NotNull ItemsReport getItemsReport()

getConnIdOperationsReport

@NotNull
public @NotNull ConnIdOperationsReport getConnIdOperationsReport()

getInternalOperationsReport

@NotNull
public @NotNull InternalOperationsReport getInternalOperationsReport()

debugDumpExtra

protected void debugDumpExtra(StringBuilder sb,
                              int indent)

Specified by:

debugDumpExtra in class ActivityState

getEnhancedClassName

@NotNull
protected @NotNull String getEnhancedClassName()

Overrides:

getEnhancedClassName in class ActivityState