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

Direct Known Subclasses:

VirtualActivityState

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

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.
@NotNull VirtualActivityState<WS>	createOrFindVirtualChildActivityState(@NotNull String childIdentifier)	Creates or finds a state for a virtual child activity.
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()
protected @NotNull Task	getTask()
@NotNull ComplexTypeDefinition	getWorkStateComplexTypeDefinition()
void	initialize(OperationResult result)	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.
void	initializeAfterRestart(@NotNull OperationResult result)	After purging of activity state on restart in ActivityTreePurger, there are some additional steps to do.
void	markAborted(OperationResultStatus resultStatus, @NotNull ActivityAbortingInformationType abortingInformation, Long endTimestamp)
void	markComplete(OperationResultStatus resultStatus, Long endTimestamp)
void	recordException(@NotNull Throwable t)
void	recordRealizationStart(long startTimestamp)
void	recordRealizationStart(XMLGregorianCalendar startTimestamp)
void	recordRunEnd(Long endTimestamp)
void	recordRunStart(Long startTimestamp)
void	setMessage(LocalizableMessage message)
void	setMessage(String message)
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, getAbortingInformation, getAbortingInformationRequired, getAbortingWorkerRef, getActivityStateDownwards, getActivityStatesUpwardsForParent, getActivityStateUpwards, getBucketProcessingRole, getCounters, getCurrentActivityStateInParentTask, getDisplayOrder, getExecutionAttempt, getParentActivityState, getPropertyRealValue, getRawRunRecordsClone, getRealizationStartTimestamp, getRealizationState, getRestartPolicyActionRequired, getResultStatus, getSimulationResultOid, getSimulationResultRef, getWorkStateItemRealValueClone, getWorkStatePropertyRealValue, getWorkStateReferenceRealValue, getWorkStateReferenceRealValues, incrementCounters, isAborted, isBeingRestarted, isBeingRestartedOrSkipped, isBeingSkipped, isBucketedWorkAborted, isBucketedWorkComplete, isComplete, isDelegating, isScavenger, isSimulationResultCreated, isWorker, setAbortingWorkerRef, setBucketProcessingRole, setDisplayOrder, setItemRealValues, setItemRealValuesCollection, setSimulationResultCreated, setSimulationResultOid, setWorkStateItemRealValues, setWorkStateItemRealValues, toString, updatePolicies

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 Details

CurrentActivityState

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

Method Details

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

initializeAfterRestart

public void initializeAfterRestart(@NotNull
 @NotNull OperationResult result)
                            throws SchemaException,
ObjectNotFoundException,
ObjectAlreadyExistsException

After purging of activity state on restart in ActivityTreePurger, there are some additional steps to do.

Throws:

SchemaException

ObjectNotFoundException

ObjectAlreadyExistsException

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

markAborted

public void markAborted(OperationResultStatus resultStatus,
 @NotNull
 @NotNull ActivityAbortingInformationType abortingInformation,
 Long endTimestamp)
                 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

setMessage

public void setMessage(String message)
                throws ActivityRunException

Throws:

ActivityRunException

setMessage

public void setMessage(LocalizableMessage message)
                throws ActivityRunException

Throws:

ActivityRunException

recordException

public void recordException(@NotNull
 @NotNull Throwable t)
                     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

createOrFindVirtualChildActivityState

@Experimental
@NotNull
public @NotNull VirtualActivityState<WS> createOrFindVirtualChildActivityState(@NotNull
 @NotNull String childIdentifier)

Creates or finds a state for a virtual child activity. May flush the task modifications, if the state does not exist yet. EXPERIMENTAL! Do not use in production code.

getLiveProgress

@NotNull
public @NotNull ActivityProgress getLiveProgress()

getLiveStatistics

@NotNull
public @NotNull ActivityStatistics getLiveStatistics()

getLiveItemProcessingStatistics

@NotNull
public @NotNull ActivityItemProcessingStatistics getLiveItemProcessingStatistics()

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