public abstract class AbstractSearchIterativeResultHandler<O extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> extends Object implements ResultHandler<O>
Modifier and Type | Class and Description |
---|---|
class |
AbstractSearchIterativeResultHandler.ProcessingRequest |
Modifier and Type | Field and Description |
---|---|
static long |
PROGRESS_UPDATE_INTERVAL |
static int |
WORKER_THREAD_WAIT_FOR_REQUEST |
Constructor and Description |
---|
AbstractSearchIterativeResultHandler(Task coordinatorTask,
String taskOperationPrefix,
String processShortName,
String contextDesc,
TaskManager taskManager) |
public static final int WORKER_THREAD_WAIT_FOR_REQUEST
public static final long PROGRESS_UPDATE_INTERVAL
public AbstractSearchIterativeResultHandler(Task coordinatorTask, String taskOperationPrefix, String processShortName, String contextDesc, TaskManager taskManager)
protected String getProcessShortName()
protected String getProcessShortNameCapitalized()
public void setProcessShortName(String processShortName)
public String getContextDesc()
public void setContextDesc(String contextDesc)
public Task getCoordinatorTask()
public String getTaskOperationPrefix()
public boolean isLogObjectProgress()
public void setLogObjectProgress(boolean logObjectProgress)
public boolean isRecordIterationStatistics()
public void setRecordIterationStatistics(boolean recordIterationStatistics)
public boolean isEnableIterationStatistics()
public void setEnableIterationStatistics(boolean enableIterationStatistics)
public boolean isEnableSynchronizationStatistics()
public void setEnableSynchronizationStatistics(boolean enableSynchronizationStatistics)
public boolean isEnableActionsExecutedStatistics()
public void setEnableActionsExecutedStatistics(boolean enableActionsExecutedStatistics)
public boolean handle(PrismObject<O> object, OperationResult parentResult)
ResultHandler
handle
in interface ResultHandler<O extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType>
object
- Resource object to process.public void signalAllItemsSubmitted()
public Float getAverageTime()
public Float getWallAverageTime()
public long getWallTime()
public void waitForCompletion(OperationResult opResult)
public void updateOperationResult(OperationResult opResult)
public void completeProcessing(Task task, OperationResult result)
protected String getDisplayName(PrismObject<O> object)
protected Throwable getException(OperationResult result)
public long heartbeat()
public long getProgress()
public long getErrors()
public boolean isStopOnError()
public void setStopOnError(boolean stopOnError)
public boolean isLogErrors()
public void setLogErrors(boolean logErrors)
protected abstract boolean handleObject(PrismObject<O> object, Task workerTask, OperationResult result) throws CommonException
CommonException
public void createWorkerThreads(Task coordinatorTask, OperationResult opResult)
Copyright © 2016 evolveum. All rights reserved.