本文整理了Java中com.evolveum.midpoint.task.api.Task.setHandlerUri()
方法的一些代码示例,展示了Task.setHandlerUri()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.setHandlerUri()
方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称:Task
方法名:setHandlerUri
[英]Sets handler URI. Handler URI indirectly specifies which class is responsible to handle the task. The handler will execute reaction to a task lifecycle events such as executing the task, task heartbeat, etc.
[中]设置处理程序URI。处理程序URI间接指定负责处理任务的类。处理程序将执行对任务生命周期事件的反应,例如执行任务、任务心跳等。
代码示例来源:origin: Evolveum/midpoint
public void evaluateExpressionInBackground(ExecuteScriptType executeScriptCommand, Task task, OperationResult parentResult) throws SchemaException {
if (!task.isTransient()) {
throw new IllegalStateException("Task must be transient");
}
if (task.getHandlerUri() != null) {
throw new IllegalStateException("Task must not have a handler");
}
OperationResult result = parentResult.createSubresult(DOT_CLASS + "evaluateExpressionInBackground");
task.setExtensionPropertyValue(SchemaConstants.SE_EXECUTE_SCRIPT, executeScriptCommand);
task.setHandlerUri(ModelPublicConstants.SCRIPT_EXECUTION_TASK_HANDLER_URI);
taskManager.switchToBackground(task, result);
result.computeStatus();
}
代码示例来源:origin: Evolveum/midpoint
task.setHandlerUri(HANDLER_URI);
代码示例来源:origin: Evolveum/midpoint
/**
* Creates and starts task with proper handler, also adds necessary information to task
* (like ReportType reference and so on).
*
* @param object
* @param task
* @param parentResult describes report which has to be created
*/
@Override
public void runReport(PrismObject<ReportType> object, PrismContainer<ReportParameterType> paramContainer, Task task, OperationResult parentResult) {
task.setHandlerUri(ReportCreateTaskHandler.REPORT_CREATE_TASK_URI);
task.setObjectRef(object.getOid(), ReportType.COMPLEX_TYPE);
try {
if (paramContainer != null && !paramContainer.isEmpty()){
task.setExtensionContainer(paramContainer);
}
} catch (SchemaException e) {
throw new SystemException(e);
}
task.setThreadStopAction(ThreadStopActionType.CLOSE);
task.makeSingle();
taskManager.switchToBackground(task, parentResult);
parentResult.setBackgroundTaskOid(task.getOid());
}
/**
代码示例来源:origin: Evolveum/midpoint
task.setHandlerUri(HANDLER_URI);
代码示例来源:origin: Evolveum/midpoint
task.setHandlerUri(HANDLER_URI);
代码示例来源:origin: Evolveum/midpoint
public void launch(AccessCertificationCampaignType campaign, OperationResult parentResult) throws SchemaException, ObjectNotFoundException {
LOGGER.debug("Launching closing task handler for campaign {} as asynchronous task", toShortString(campaign));
OperationResult result = parentResult.createSubresult(CLASS_DOT + "launch");
result.addParam("campaignOid", campaign.getOid());
Task task = taskManager.createTaskInstance();
task.setHandlerUri(HANDLER_URI);
task.setName(new PolyStringType("Closing " + campaign.getName()));
task.setObjectRef(ObjectTypeUtil.createObjectRef(campaign, prismContext));
task.setOwner(repositoryService.getObject(UserType.class, SystemObjectsType.USER_ADMINISTRATOR.value(), null, result));
taskManager.switchToBackground(task, result);
result.setBackgroundTaskOid(task.getOid());
if (result.isInProgress()) {
result.recordStatus(OperationResultStatus.IN_PROGRESS, "Closing task "+task+" was successfully started, please use Server Tasks to see its status.");
}
LOGGER.trace("Closing task for {} switched to background, control thread returning with task {}", toShortString(campaign), task);
}
代码示例来源:origin: Evolveum/midpoint
public void launch(AccessCertificationCampaignType campaign, OperationResult parentResult) throws SchemaException, ObjectNotFoundException {
LOGGER.info("Launching remediation task handler for campaign {} as asynchronous task", ObjectTypeUtil.toShortString(campaign));
OperationResult result = parentResult.createSubresult(CLASS_DOT + "launch");
result.addParam("campaignOid", campaign.getOid());
Task task = taskManager.createTaskInstance();
// Set handler URI so we will be called back
task.setHandlerUri(HANDLER_URI);
// Readable task name
PolyStringType polyString = new PolyStringType("Remediation for " + campaign.getName());
task.setName(polyString);
// Set reference to the resource
task.setObjectRef(ObjectTypeUtil.createObjectRef(campaign, prismContext));
task.setOwner(repositoryService.getObject(UserType.class, SystemObjectsType.USER_ADMINISTRATOR.value(), null, result));
taskManager.switchToBackground(task, result);
result.setBackgroundTaskOid(task.getOid());
if (result.isInProgress()) {
result.recordStatus(OperationResultStatus.IN_PROGRESS, "Remediation task "+task+" was successfully started, please use Server Tasks to see its status.");
}
LOGGER.trace("Remediation for {} switched to background, control thread returning with task {}", ObjectTypeUtil.toShortString(campaign), task);
}
代码示例来源:origin: Evolveum/midpoint
reconTask.setBinding(TaskBinding.LOOSE);
reconTask.setInitialExecutionStatus(TaskExecutionStatus.RUNNABLE);
reconTask.setHandlerUri(RecomputeTaskHandler.HANDLER_URI);
reconTask.setCategory(TaskCategory.RECOMPUTATION);
taskManager.switchToBackground(reconTask, result);
代码示例来源:origin: Evolveum/midpoint
@Test
public void test507ScriptingUsersInBackgroundAssign() throws Exception {
final String TEST_NAME = "test507ScriptingUsersInBackgroundAssign";
TestUtil.displayTestTitle(this, TEST_NAME);
// GIVEN
Task task = createTask(DOT_CLASS + TEST_NAME);
task.setOwner(getUser(USER_ADMINISTRATOR_OID));
OperationResult result = task.getResult();
ExecuteScriptType exec = prismContext.parserFor(SCRIPTING_USERS_IN_BACKGROUND_ASSIGN_FILE).parseRealValue();
// WHEN
task.setExtensionPropertyValue(SchemaConstants.SE_EXECUTE_SCRIPT, exec);
task.setHandlerUri(ModelPublicConstants.SCRIPT_EXECUTION_TASK_HANDLER_URI);
dummyTransport.clearMessages();
boolean notificationsDisabled = notificationManager.isDisabled();
notificationManager.setDisabled(false);
taskManager.switchToBackground(task, result);
waitForTaskFinish(task.getOid(), false);
task.refresh(result);
// THEN
display(task.getResult());
TestUtil.assertSuccess(task.getResult());
PrismObject<UserType> admin = getUser(USER_ADMINISTRATOR_OID);
display("admin after operation", admin);
assertAssignedRole(admin, ROLE_EMPTY_OID);
display("dummy transport", dummyTransport);
notificationManager.setDisabled(notificationsDisabled);
assertEquals("Wrong # of messages in dummy transport", 1,
emptyIfNull(dummyTransport.getMessages("dummy:simpleUserNotifier")).size());
}
代码示例来源:origin: Evolveum/midpoint
t1.setHandlerUri(AbstractTaskManagerTest.L3_TASK_HANDLER_URI);
taskManager.switchToBackground(t1, opResult);
t2.setHandlerUri(AbstractTaskManagerTest.SINGLE_TASK_HANDLER_URI);
taskManager.switchToBackground(t2, opResult);
代码示例来源:origin: Evolveum/midpoint
.findOrCreateProperty(USER_DESCRIPTION_TASK_EXTENSION_PROPERTY)
.addRealValue("admin description");
task.setHandlerUri(ModelPublicConstants.SCRIPT_EXECUTION_TASK_HANDLER_URI);
内容来源于网络,如有侵权,请联系作者删除!