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 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(OperationResult result)
public long heartbeat()
public long getProgress()
public long getErrors()
public boolean isStopOnError()
public void setStopOnError(boolean stopOnError)
protected abstract boolean handleObject(PrismObject<O> object, Task workerTask, OperationResult result) throws CommonException
CommonException
public void createWorkerThreads(Task coordinatorTask, OperationResult opResult)
Copyright © 2015 evolveum. All rights reserved.