本文整理了Java中com.evolveum.midpoint.task.api.Task.getHandlerUri()
方法的一些代码示例,展示了Task.getHandlerUri()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.getHandlerUri()
方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称: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);
内容来源于网络,如有侵权,请联系作者删除!