com.evolveum.midpoint.task.api.TaskManager类的使用及代码示例

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

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

TaskManager介绍

[英]Task Manager Interface.

Status: public Stability: DRAFT
[中]任务管理器界面。
现状：公共稳定：草案

代码示例

代码示例来源：origin: Evolveum/midpoint

  1. protected Task createTaskInstance(String operationName) {
  2.   // TODO: better task initialization
  3.   Task task = taskManager.createTaskInstance(operationName);
  4.   setTaskOwner(task);
  5.   task.setChannel(SchemaConstants.CHANNEL_WEB_SERVICE_URI);
  6.   return task;
  7. }

代码示例来源：origin: Evolveum/midpoint

  1. public Task getShadowTask(Map<String, Object> variables, OperationResult result) throws SchemaException, ObjectNotFoundException {
  2.   String oid = (String) variables.get(CommonProcessVariableNames.VARIABLE_MIDPOINT_TASK_OID);
  3.   if (oid != null) {
  4.     return taskManager.getTask(oid, result);
  5.   } else {
  6.     return null;
  7.   }
  8. }

代码示例来源：origin: Evolveum/midpoint

  1. @PostConstruct
  2.   private void initialize() {
  3.     taskManager.registerHandler(MODEL_OPERATION_TASK_URI, this);
  4.   }
  5. }

代码示例来源：origin: Evolveum/midpoint

  1. @PostConstruct
  2. private void initialize() {
  3.   taskManager.registerHandler(HANDLER_URI, this);
  4.   taskManager.registerAdditionalHandlerUri(FIRST_STAGE_HANDLER_URI, this);
  5.   taskManager.registerAdditionalHandlerUri(SECOND_STAGE_HANDLER_URI, this);
  6.   taskManager.registerAdditionalHandlerUri(THIRD_STAGE_HANDLER_URI, this);
  7. }

代码示例来源：origin: Evolveum/midpoint

  1. protected void resetTriggerTask(String taskOid, File taskFile, OperationResult result)
  2.     throws ObjectNotFoundException, SchemaException, ObjectAlreadyExistsException, FileNotFoundException {
  3.   taskManager.suspendAndDeleteTasks(Collections.singletonList(taskOid), 60000L, true, result);
  4.   importObjectFromFile(taskFile, result);
  5.   taskManager.suspendTasks(Collections.singletonList(taskOid), 60000L, result);
  6.   modifySystemObjectInRepo(TaskType.class, taskOid,
  7.       prismContext.deltaFor(TaskType.class)
  8.           .item(TaskType.F_SCHEDULE).replace()
  9.           .asItemDeltas(),
  10.       result);
  11.   taskManager.resumeTasks(singleton(taskOid), result);
  12. }

代码示例来源：origin: Evolveum/midpoint

  1. public void launch(AccessCertificationCampaignType campaign, OperationResult parentResult) throws SchemaException, ObjectNotFoundException {
  2.   LOGGER.debug("Launching closing task handler for campaign {} as asynchronous task", toShortString(campaign));
  3.   OperationResult result = parentResult.createSubresult(CLASS_DOT + "launch");
  4.   result.addParam("campaignOid", campaign.getOid());
  5.   Task task = taskManager.createTaskInstance();
  6.   task.setHandlerUri(HANDLER_URI);
  7.   task.setName(new PolyStringType("Closing " + campaign.getName()));
  8.   task.setObjectRef(ObjectTypeUtil.createObjectRef(campaign, prismContext));
  9.   task.setOwner(repositoryService.getObject(UserType.class, SystemObjectsType.USER_ADMINISTRATOR.value(), null, result));
  10.   taskManager.switchToBackground(task, result);
  11.   result.setBackgroundTaskOid(task.getOid());
  12.   if (result.isInProgress()) {
  13.     result.recordStatus(OperationResultStatus.IN_PROGRESS, "Closing task "+task+" was successfully started, please use Server Tasks to see its status.");
  14.   }
  15.   LOGGER.trace("Closing task for {} switched to background, control thread returning with task {}", toShortString(campaign), task);
  16. }

代码示例来源：origin: Evolveum/midpoint

  1. @Test
  2. public void test010Sanity() throws Exception {
  3.   final String TEST_NAME = "test010Sanity";
  4.   TestUtil.displayTestTitle(TEST_NAME);
  5.   final OperationResult result = new OperationResult(TestSynchronization.class.getName()
  6.       + "." + TEST_NAME);
  7.   // WHEN
  8.   PrismObject<ResourceType> resource = provisioningService.getObject(ResourceType.class, resourceType.getOid(), null, taskManager.createTaskInstance(), result);
  9.   
  10.   // THEN
  11.   assertNotNull("Resource is null", resource);
  12.   display("getObject(resource)", resource);
  13.   
  14.   result.computeStatus();
  15.   display("getObject(resource) result", result);
  16.   TestUtil.assertSuccess(result);
  17.   
  18.   // Make sure these were generated
  19.   assertNotNull("No resource schema", resource.asObjectable().getSchema());
  20.   assertNotNull("No native capabilities", resource.asObjectable().getCapabilities().getNative());
  21.   Task syncTask = taskManager.getTask(SYNC_TASK_OID, result);
  22.   AssertJUnit.assertNotNull(syncTask);
  23.   assertSyncToken(syncTask, 0, result);
  24. }

代码示例来源：origin: Evolveum/midpoint

  1. Task task = taskManager.createTaskInstance(TestPolicyRules2.class.getName() + "." + TEST_NAME);
  2. OperationResult result = task.getResult();
  3.     .ownerRef(userAdministrator.getOid(), UserType.COMPLEX_TYPE)
  4.     .objectRef(USER_JACK_OID, UserType.COMPLEX_TYPE, SchemaConstants.ORG_DEFAULT);
  5. String approvalTaskOid = taskManager.addTask(approvalTask.asPrismObject(), result);
  6. System.out.println("Approval task OID = " + approvalTaskOid);

代码示例来源：origin: Evolveum/midpoint

  1. Task task = taskManager.getTask(TASK_USER_RECOMPUTE_OID, retrieveTaskResult(), result);
  2. result.computeStatus();
  3. display("getTask result", result);
  4. taskManager.deleteTask(TASK_USER_RECOMPUTE_OID, result);

代码示例来源：origin: Evolveum/midpoint

  1. public void evaluateExpressionInBackground(ExecuteScriptType executeScriptCommand, Task task, OperationResult parentResult) throws SchemaException {
  2.   if (!task.isTransient()) {
  3.     throw new IllegalStateException("Task must be transient");
  4.   }
  5.   if (task.getHandlerUri() != null) {
  6.     throw new IllegalStateException("Task must not have a handler");
  7.   }
  8.   OperationResult result = parentResult.createSubresult(DOT_CLASS + "evaluateExpressionInBackground");
  9.   task.setExtensionPropertyValue(SchemaConstants.SE_EXECUTE_SCRIPT, executeScriptCommand);
  10.   task.setHandlerUri(ModelPublicConstants.SCRIPT_EXECUTION_TASK_HANDLER_URI);
  11.   taskManager.switchToBackground(task, result);
  12.   result.computeStatus();
  13. }

代码示例来源：origin: Evolveum/midpoint

  1. String addTask(PrismObject<TaskType> taskPrism, RepoAddOptions options, OperationResult parentResult)
  2.     throws ObjectAlreadyExistsException, SchemaException;

代码示例来源：origin: Evolveum/midpoint

  1. boolean suspended = taskManager.suspendTasks(singleton(TASK_TRIGGER_SCANNER_OID), 20000L, result);
  2. assertTrue("trigger scanner task was not suspended (before operation)", suspended);
  3. testTriggerHandler.setDelay(ONE_DAY);
  4. taskManager.resumeTasks(singleton(TASK_TRIGGER_SCANNER_OID), result);
  5. suspended = taskManager.suspendTasks(singleton(TASK_TRIGGER_SCANNER_OID), 20000L, result);
  6. assertTrue("trigger scanner task was not suspended (after operation)", suspended);

代码示例来源：origin: Evolveum/midpoint

  1. private void deleteTaskChecked(String oid, Statistics s, OperationResult result) {
  2.   try {
  3.     taskManager.deleteTask(oid, result);
  4.     s.tasksRemoved++;
  5.   } catch (ObjectNotFoundException e) {
  6.     LoggingUtils.logUnexpectedException(LOGGER, "Couldn't remove task {} as it seems to be no longer existing", e, oid);
  7.   } catch (RuntimeException|SchemaException e) {
  8.     LoggingUtils.logUnexpectedException(LOGGER, "Couldn't remove task {}", e, oid);
  9.     s.wrongTasksRemaining++;
  10.   }
  11. }

代码示例来源：origin: Evolveum/midpoint

  1. taskManager.reconcileWorkers(task.getOid(), options, opResult);
  2.   taskManager.resumeTasks(TaskUtil.tasksToOids(task.listSubtasks(true, opResult)), opResult);
  3.   LOGGER.info("Worker tasks were successfully created for coordinator {}", task);
  4. } catch (SchemaException | ObjectNotFoundException | ObjectAlreadyExistsException e) {

代码示例来源：origin: Evolveum/midpoint

  1. @Override
  2. public void resumeTasks(Collection<String> taskOids, Task operationTask, OperationResult parentResult) throws SecurityViolationException, ObjectNotFoundException, SchemaException, ExpressionEvaluationException, CommunicationException, ConfigurationException {
  3.   authorizeTaskCollectionOperation(ModelAuthorizationAction.RESUME_TASK, taskOids, operationTask, parentResult);
  4.   taskManager.resumeTasks(taskOids, parentResult);
  5. }

代码示例来源：origin: Evolveum/midpoint

  1. taskManager.deleteTask(oid, result);
  2. } else if (NodeType.class.isAssignableFrom(objectTypeClass)) {
  3.   taskManager.deleteNode(oid, result);
  4. } else if (ObjectTypes.isClassManagedByProvisioning(objectTypeClass)) {
  5.   ProvisioningOperationOptions provisioningOptions = getProvisioningOptions(context, options,

代码示例来源：origin: Evolveum/midpoint

  1. public void launch(AccessCertificationCampaignType campaign, OperationResult parentResult) throws SchemaException, ObjectNotFoundException {
  2.   LOGGER.info("Launching remediation task handler for campaign {} as asynchronous task", ObjectTypeUtil.toShortString(campaign));
  3.   OperationResult result = parentResult.createSubresult(CLASS_DOT + "launch");
  4.   result.addParam("campaignOid", campaign.getOid());
  5.   Task task = taskManager.createTaskInstance();
  6.   // Set handler URI so we will be called back
  7.   task.setHandlerUri(HANDLER_URI);
  8.   // Readable task name
  9.   PolyStringType polyString = new PolyStringType("Remediation for " + campaign.getName());
  10.   task.setName(polyString);
  11.   // Set reference to the resource
  12.   task.setObjectRef(ObjectTypeUtil.createObjectRef(campaign, prismContext));
  13.   task.setOwner(repositoryService.getObject(UserType.class, SystemObjectsType.USER_ADMINISTRATOR.value(), null, result));
  14.   taskManager.switchToBackground(task, result);
  15.   result.setBackgroundTaskOid(task.getOid());
  16.   if (result.isInProgress()) {
  17.     result.recordStatus(OperationResultStatus.IN_PROGRESS, "Remediation task "+task+" was successfully started, please use Server Tasks to see its status.");
  18.   }
  19.   LOGGER.trace("Remediation for {} switched to background, control thread returning with task {}", ObjectTypeUtil.toShortString(campaign), task);
  20. }

代码示例来源：origin: Evolveum/midpoint

  1. Task task = taskManager.getTask(TASK_OPENDJ_RECON_OID, result);
  2. result.computeStatus();
  3. display("getTask result", result);
  4. taskManager.deleteTask(TASK_OPENDJ_RECON_OID, result);

代码示例来源：origin: Evolveum/midpoint

  1. private Task submitTask(WfTaskCreationInstruction instruction, Task parentTask, WfConfigurationType wfConfigurationType, String channelOverride, OperationResult result) throws SchemaException, ObjectNotFoundException {
  2.   Task wfTask = instruction.createTask(this, parentTask, wfConfigurationType);
  3.   if (channelOverride != null) {
  4.     wfTask.setChannel(channelOverride);
  5.   }
  6.   if (LOGGER.isTraceEnabled()) {
  7.     LOGGER.trace("Switching workflow root or child task to background:\n{}", wfTask.debugDump());
  8.   }
  9.   taskManager.switchToBackground(wfTask, result);
  10.   return wfTask;
  11. }

代码示例来源：origin: Evolveum/midpoint

  1. protected void addTask(File file) throws SchemaException, IOException, ObjectAlreadyExistsException {
  2.   taskManager.addTask(prismContext.parseObject(file), new OperationResult("addTask"));
  3. }

内容来源于网络，如有侵权，请联系作者删除！

taskmanager

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com