public abstract class AbstractSearchIterativeTaskHandler<O extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType,H extends AbstractSearchIterativeResultHandler<O>> extends Object implements TaskHandler
Modifier and Type | Field and Description |
---|---|
protected ModelObjectResolver |
modelObjectResolver |
protected PrismContext |
prismContext |
protected RepositoryService |
repositoryService |
protected SecurityEnforcer |
securityEnforcer |
protected TaskManager |
taskManager |
Modifier | Constructor and Description |
---|---|
protected |
AbstractSearchIterativeTaskHandler(String taskName,
String taskOperationPrefix) |
Modifier and Type | Method and Description |
---|---|
protected abstract H |
createHandler(TaskRunResult runResult,
Task coordinatorTask,
OperationResult opResult) |
protected abstract ObjectQuery |
createQuery(H handler,
TaskRunResult runResult,
Task task,
OperationResult opResult)
Handler parameter may be used to pass task instance state between the calls.
|
protected ObjectQuery |
createQueryFromTask(H handler,
TaskRunResult runResult,
Task task,
OperationResult opResult)
Ready-made implementation of createQuery - gets and parses objectQuery extension property.
|
protected void |
finish(H handler,
TaskRunResult runResult,
Task task,
OperationResult opResult) |
protected QueryType |
getObjectQueryTypeFromTask(Task task) |
protected abstract Class<? extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> |
getType(Task task) |
protected Class<? extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> |
getTypeFromTask(Task task,
Class<? extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> defaultType) |
Long |
heartbeat(Task task) |
protected boolean |
initializeRun(H handler,
TaskRunResult runResult,
Task task,
OperationResult opResult)
Used to properly initialize the "run", which is kind of task instance.
|
boolean |
isEnableActionsExecutedStatistics() |
boolean |
isEnableIterationStatistics() |
boolean |
isEnableSynchronizationStatistics() |
boolean |
isLogFinishInfo() |
boolean |
isPreserveStatistics() |
void |
refreshStatus(Task task) |
protected <T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> |
resolveObjectRef(Class<T> type,
TaskRunResult runResult,
Task task,
OperationResult opResult) |
TaskRunResult |
run(Task coordinatorTask) |
TaskRunResult |
runInternal(Task coordinatorTask) |
void |
setEnableActionsExecutedStatistics(boolean enableActionsExecutedStatistics) |
void |
setEnableIterationStatistics(boolean enableIterationStatistics) |
void |
setEnableSynchronizationStatistics(boolean enableSynchronizationStatistics) |
void |
setLogFinishInfo(boolean logFinishInfo) |
void |
setPreserveStatistics(boolean preserveStatistics) |
protected boolean |
useRepositoryDirectly(H resultHandler,
TaskRunResult runResult,
Task coordinatorTask,
OperationResult opResult) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCategoryName, getCategoryNames
@Autowired protected TaskManager taskManager
@Autowired protected ModelObjectResolver modelObjectResolver
@Autowired @Qualifier(value="cacheRepositoryService") protected RepositoryService repositoryService
@Autowired protected PrismContext prismContext
@Autowired protected SecurityEnforcer securityEnforcer
public boolean isLogFinishInfo()
public boolean isPreserveStatistics()
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 void setPreserveStatistics(boolean preserveStatistics)
public void setLogFinishInfo(boolean logFinishInfo)
public TaskRunResult run(Task coordinatorTask)
run
in interface TaskHandler
public TaskRunResult runInternal(Task coordinatorTask)
protected void finish(H handler, TaskRunResult runResult, Task task, OperationResult opResult) throws SchemaException
SchemaException
public Long heartbeat(Task task)
heartbeat
in interface TaskHandler
protected <T extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> T resolveObjectRef(Class<T> type, TaskRunResult runResult, Task task, OperationResult opResult)
public void refreshStatus(Task task)
refreshStatus
in interface TaskHandler
protected abstract ObjectQuery createQuery(H handler, TaskRunResult runResult, Task task, OperationResult opResult) throws SchemaException
SchemaException
protected boolean useRepositoryDirectly(H resultHandler, TaskRunResult runResult, Task coordinatorTask, OperationResult opResult)
protected abstract Class<? extends com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType> getType(Task task)
protected abstract H createHandler(TaskRunResult runResult, Task coordinatorTask, OperationResult opResult) throws SchemaException, SecurityViolationException
protected boolean initializeRun(H handler, TaskRunResult runResult, Task task, OperationResult opResult)
protected ObjectQuery createQueryFromTask(H handler, TaskRunResult runResult, Task task, OperationResult opResult) throws SchemaException
SchemaException
Copyright © 2016 evolveum. All rights reserved.