com.evolveum.midpoint.task.api.Task.setHandlerUri()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(6.8k)|赞(0)|评价(0)|浏览(87)

本文整理了Java中com.evolveum.midpoint.task.api.Task.setHandlerUri()方法的一些代码示例,展示了Task.setHandlerUri()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.setHandlerUri()方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称:Task
方法名:setHandlerUri

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);

相关文章

微信公众号

最新文章

更多