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

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

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

Task.getHandlerUri介绍

[英]Returns 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

private Integer getPartition(Task task) {
  String handlerUri = task.getHandlerUri();
  if (ModelPublicConstants.PARTITIONED_FOCUS_VALIDITY_SCANNER_TASK_HANDLER_URI_1.equals(handlerUri)) {
    return 1;
  } else if (ModelPublicConstants.PARTITIONED_FOCUS_VALIDITY_SCANNER_TASK_HANDLER_URI_2.equals(handlerUri)) {
    return 2;
  } else {
    return null;
  }
}

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

@Override
public synchronized void onTaskFinish(Task task, TaskRunResult runResult) {
  if (!ModelOperationTaskHandler.MODEL_OPERATION_TASK_URI.equals(task.getHandlerUri())) {
    return;
  }
  System.out.println(Thread.currentThread().getName() + ": Finishing " + task + ", handler uri " + task.getHandlerUri());
  assert executing.getOid().equals(task.getOid());
  executing = null;
}

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

@Override
protected String getBody(Event event, GeneralNotifierType generalNotifierType, String transport, Task opTask, OperationResult opResult) throws SchemaException {
  final TaskEvent taskEvent = (TaskEvent) event;
  final Task task = taskEvent.getTask();
  final String taskName = PolyString.getOrig(task.getName());
  StringBuilder body = new StringBuilder();
  body.append("Notification about task-related operation.\n\n");
  body.append("Task: ").append(taskName).append("\n");
  body.append("Handler: ").append(task.getHandlerUri()).append("\n\n");
  if (taskEvent.getTaskRunResult() != null) {
    body.append("Run result status: ").append(taskEvent.getTaskRunResult().getRunResultStatus()).append("\n");
  }
  body.append("Status: ").append(taskEvent.getOperationResultStatus()).append("\n");
  String message = taskEvent.getMessage();
  if (StringUtils.isNotBlank(message)) {
    body.append("Message: ").append(message).append("\n");
  }
  body.append("Progress: ").append(taskEvent.getProgress()).append("\n");
  body.append("\n");
  body.append("Notification created on: ").append(new Date()).append("\n\n");
  if (task.getOwner() != null) {
    UserType owner = task.getOwner().asObjectable();
    body.append("Task owner: ");
    body.append(owner.getFullName()).append(" (").append(owner.getName()).append(")");
    body.append("\n");
  }
  body.append("Channel: ").append(event.getChannel()).append("\n\n");
  return body.toString();
}

代码示例来源: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

@Override
public synchronized void onTaskStart(Task task) {
  if (!ModelOperationTaskHandler.MODEL_OPERATION_TASK_URI.equals(task.getHandlerUri())) {
    return;
  }
  System.out.println(Thread.currentThread().getName() + ": Starting " + task + ", handler uri " + task.getHandlerUri() + ", groups " + task.getGroups());
  if (executing != null) {
    exception = new IllegalStateException("Started task " + task + " but another one is already executing: " + executing);
    System.out.println(exception.getMessage());
    display("newly started task", task);
    display("already executing task", executing);
    suspendTasks();
  }
  executing = task;
}

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

TaskWorkBucketProcessingResult previousRunResult) {
String partition = task.getHandlerUri().substring(TaskConstants.NOOP_TASK_HANDLER_URI.length());  // empty or #1..#4

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

tb.usingJobData("handlerUri", task.getHandlerUri());

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

return;
if (task.getHandlerUri() == null) {
  LOGGER.trace("No handler in task being unpaused - closing it: {}", task);
  closeTask(task, result);

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

AssertJUnit.assertNotNull("Handler is gone", task1.getHandlerUri());
AssertJUnit.assertTrue("Other handlers are still present",
    task1.getOtherHandlersUriStack() == null || task1.getOtherHandlersUriStack().getUriStackEntry().isEmpty());

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

replacements.put("index", String.valueOf(index));
replacements.put("masterTaskName", String.valueOf(masterTask.getName().getOrig()));
replacements.put("masterTaskHandlerUri", masterTask.getHandlerUri());

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

assertEquals("Invalid current handler", ModelOperationTaskHandler.MODEL_OPERATION_TASK_URI, rootTask.getHandlerUri());

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

AssertJUnit.assertNotNull("Handler is gone", task.getHandlerUri());
AssertJUnit.assertTrue("Other handlers are still present",
    task.getOtherHandlersUriStack() == null || task.getOtherHandlersUriStack().getUriStackEntry().isEmpty());

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

AssertJUnit.assertNotNull("Handler is gone", task.getHandlerUri());
AssertJUnit.assertTrue("Other handlers are still present",
    task.getOtherHandlersUriStack() == null || task.getOtherHandlersUriStack().getUriStackEntry().isEmpty());

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

AssertJUnit.assertNotNull("Handler is gone", task.getHandlerUri());
AssertJUnit.assertTrue("Other handlers are still present",
    task.getOtherHandlersUriStack() == null || task.getOtherHandlersUriStack().getUriStackEntry().isEmpty());

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

AssertJUnit.assertEquals("Handler after 2xPUSH is not OK", "http://no-handler.org/2", task001.getHandlerUri());
AssertJUnit.assertEquals("Schedule after 2xPUSH is not OK", st2, task001.getSchedule());
AssertJUnit.assertEquals("Number of handlers is not OK", 3, task.getHandlersCount());
AssertJUnit.assertEquals("Handler URI after first POP is not correct", "http://no-handler.org/1", task001.getHandlerUri());
AssertJUnit.assertEquals("Schedule after first POP is not correct", st1, task001.getSchedule());
AssertJUnit.assertEquals("Binding after first POP is not correct", TaskBinding.TIGHT, task001.getBinding());
AssertJUnit.assertEquals("Handler URI after second POP is not correct", "http://no-handler.org/", task001.getHandlerUri());
AssertJUnit.assertEquals("Schedule after second POP is not correct", st0, task001.getSchedule());
AssertJUnit.assertEquals("Binding after second POP is not correct", TaskBinding.LOOSE, task001.getBinding());
task001.refresh(result);
AssertJUnit.assertEquals("Handler URI after third POP is not correct", "http://no-handler.org/", task001.getHandlerUri());
AssertJUnit.assertEquals("Task state after third POP is not CLOSED", TaskExecutionStatus.CLOSED, task001.getExecutionStatus());

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

String handlerUri = localCoordinatorTask.getHandlerUri();
Stage stage = getStage(handlerUri);
LOGGER.trace("ReconciliationTaskHandler.run starting (stage: {})", stage);

相关文章

微信公众号

最新文章

更多