本文整理了Java中com.evolveum.midpoint.task.api.Task.getOid()
方法的一些代码示例,展示了Task.getOid()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.getOid()
方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称:Task
方法名:getOid
[英]Returns task OID. Only persistent tasks have OID. This returns null if the task is not persistent.
[中]返回任务OID。只有持久性任务具有OID。如果任务不是持久性的,则返回null。
代码示例来源:origin: Evolveum/midpoint
public CounterSepcification getCounterSpec(Task task) {
if (task.getOid() == null) {
return null;
}
return countersMap.get(task.getOid());
}
}
代码示例来源:origin: Evolveum/midpoint
private synchronized void cleanupProcessedOids(Task coordinatorTask) {
Validate.notNull(coordinatorTask.getOid(), "Task OID is null");
processedOidsMap.remove(coordinatorTask.getOid());
}
代码示例来源:origin: Evolveum/midpoint
private synchronized void cleanupProcessedOids(Task coordinatorTask) {
Validate.notNull(coordinatorTask.getOid(), "Task OID is null");
processedTriggersMap.remove(coordinatorTask.getOid());
}
代码示例来源:origin: Evolveum/midpoint
private synchronized void initProcessedOids(Task coordinatorTask) {
Validate.notNull(coordinatorTask.getOid(), "Task OID is null");
processedOidsMap.put(coordinatorTask.getOid(), new HashSet<>());
}
代码示例来源:origin: Evolveum/midpoint
private synchronized void initProcessedTriggers(Task coordinatorTask) {
Validate.notNull(coordinatorTask.getOid(), "Task OID is null");
processedTriggersMap.put(coordinatorTask.getOid(), new HashMap<>());
}
代码示例来源:origin: Evolveum/midpoint
private synchronized boolean oidAlreadySeen(Task coordinatorTask, String objectOid) {
Validate.notNull(coordinatorTask.getOid(), "Coordinator task OID is null");
Set<String> oids = processedOidsMap.get(coordinatorTask.getOid());
if (oids == null) {
throw new IllegalStateException("ProcessedOids set was not initialized for task = " + coordinatorTask);
}
return !oids.add(objectOid);
}
代码示例来源:origin: Evolveum/midpoint
public static TriggerKey createTriggerKeyForTask(Task t) {
return new TriggerKey(t.getOid());
}
代码示例来源: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
public void closeTaskWithoutSavingState(Task task, OperationResult parentResult) {
try {
OperationResult taskResult = updateTaskResult(task, parentResult);
task.close(taskResult, false, parentResult);
} catch (ObjectNotFoundException | SchemaException e) {
throw new SystemException(e); // shouldn't occur
}
executionManager.removeTaskFromQuartz(task.getOid(), parentResult);
}
代码示例来源:origin: Evolveum/midpoint
public void closeTask(Task task, OperationResult parentResult) throws ObjectNotFoundException, SchemaException {
try {
OperationResult taskResult = updateTaskResult(task, parentResult);
task.close(taskResult, true, parentResult);
} finally {
if (task.isPersistent()) {
executionManager.removeTaskFromQuartz(task.getOid(), parentResult);
}
}
}
代码示例来源:origin: Evolveum/midpoint
private void markWorkComplete(Task task, OperationResult result)
throws ObjectAlreadyExistsException, ObjectNotFoundException, SchemaException {
List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(TaskType.class)
.item(TaskType.F_WORK_STATE, TaskWorkStateType.F_ALL_WORK_COMPLETE).replace(true)
.asItemDeltas();
repositoryService.modifyObject(TaskType.class, task.getOid(), itemDeltas, result);
}
代码示例来源:origin: Evolveum/midpoint
private void deleteWorkState(Task task, OperationResult opResult) throws SchemaException, ObjectNotFoundException, ObjectAlreadyExistsException {
List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(TaskType.class)
.item(TaskType.F_WORK_STATE).replace()
.asItemDeltas();
repositoryService.modifyObject(TaskType.class, task.getOid(), itemDeltas, opResult);
}
代码示例来源:origin: Evolveum/midpoint
private void deleteBuckets(Task task, OperationResult opResult) throws SchemaException, ObjectNotFoundException, ObjectAlreadyExistsException {
List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(TaskType.class)
.item(TaskType.F_WORK_STATE, TaskWorkStateType.F_BUCKET).replace()
.asItemDeltas();
repositoryService.modifyObject(TaskType.class, task.getOid(), itemDeltas, opResult);
}
代码示例来源:origin: Evolveum/midpoint
private static void removeSelectedTriggers(Task wfTask, List<PrismContainerValue<TriggerType>> toDelete, OperationResult result) {
try {
LOGGER.trace("About to delete {} triggers from {}: {}", toDelete.size(), wfTask, toDelete);
List<ItemDelta<?, ?>> itemDeltas = getPrismContext().deltaFor(TaskType.class)
.item(TaskType.F_TRIGGER).delete(toDelete)
.asItemDeltas();
getCacheRepositoryService().modifyObject(TaskType.class, wfTask.getOid(), itemDeltas, result);
} catch (SchemaException|ObjectNotFoundException|ObjectAlreadyExistsException|RuntimeException e) {
LoggingUtils.logUnexpectedException(LOGGER, "Couldn't remove triggers from task {}", e, wfTask);
}
}
代码示例来源:origin: Evolveum/midpoint
@Override
protected void assertLastScanTimestamp(String taskOid, XMLGregorianCalendar startCal, XMLGregorianCalendar endCal)
throws ObjectNotFoundException, SchemaException, SecurityViolationException, CommunicationException,
ConfigurationException, ExpressionEvaluationException {
OperationResult result = new OperationResult(TestValidityRecomputeTaskPartitioned.class.getName() + ".assertLastScanTimestamp");
Task master = taskManager.getTask(taskOid, result);
for (Task subtask : master.listSubtasks(result)) {
super.assertLastScanTimestamp(subtask.getOid(), startCal, endCal);
}
}
}
代码示例来源:origin: Evolveum/midpoint
private void setOrUpdateEstimatedNumberOfBuckets(Task task, WorkSegmentationStrategy workStateStrategy, OperationResult result)
throws SchemaException, ObjectAlreadyExistsException, ObjectNotFoundException {
Integer number = workStateStrategy.estimateNumberOfBuckets(task.getWorkState());
if (number != null && (task.getWorkState() == null || !number.equals(task.getWorkState().getNumberOfBuckets()))) {
List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(TaskType.class)
.item(TaskType.F_WORK_STATE, TaskWorkStateType.F_NUMBER_OF_BUCKETS).replace(number)
.asItemDeltas();
repositoryService.modifyObject(TaskType.class, task.getOid(), itemDeltas, result);
}
}
代码示例来源:origin: Evolveum/midpoint
private void renameWorker(Task currentWorker, String newName, OperationResult result)
throws ObjectAlreadyExistsException, ObjectNotFoundException, SchemaException {
List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(TaskType.class)
.item(TaskType.F_NAME).replace(PolyString.fromOrig(newName))
.asItemDeltas();
LOGGER.info("Renaming worker task {} to {}", currentWorker, newName);
repositoryService.modifyObject(TaskType.class, currentWorker.getOid(), itemDeltas, result);
}
代码示例来源:origin: Evolveum/midpoint
private void moveWorker(Task worker, WorkerKey shouldBe, OperationResult result)
throws ObjectAlreadyExistsException, ObjectNotFoundException, SchemaException {
List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(TaskType.class)
.item(TaskType.F_EXECUTION_CONSTRAINTS, TaskExecutionConstraintsType.F_GROUP).replace(shouldBe.group)
.item(TaskType.F_NAME).replace(PolyString.fromOrig(shouldBe.name))
.asItemDeltas();
LOGGER.info("Moving worker task {} to {} as {}", worker, shouldBe.group, shouldBe.name);
taskManager.modifyTask(worker.getOid(), itemDeltas, result);
}
代码示例来源:origin: Evolveum/midpoint
private <F extends ObjectType> void applyCreateMetadata(LensContext<F> context, MetadataType metaData, XMLGregorianCalendar now, Task task) {
String channel = LensUtil.getChannel(context, task);
metaData.setCreateChannel(channel);
metaData.setCreateTimestamp(now);
if (task.getOwner() != null) {
metaData.setCreatorRef(createObjectRef(task.getOwner(), prismContext));
}
metaData.setCreateTaskRef(task.getOid() != null ? createObjectRef(task.getTaskPrismObject(), prismContext) : null);
}
代码示例来源:origin: Evolveum/midpoint
public <F extends ObjectType, T extends ObjectType> Collection<ItemDelta<?,?>> createModifyMetadataDeltas(LensContext<F> context,
ItemPath metadataPath, Class<T> objectType, XMLGregorianCalendar now, Task task) throws SchemaException {
return prismContext.deltaFor(objectType)
.item(metadataPath.append(MetadataType.F_MODIFY_CHANNEL)).replace(LensUtil.getChannel(context, task))
.item(metadataPath.append(MetadataType.F_MODIFY_TIMESTAMP)).replace(now)
.item(metadataPath.append(MetadataType.F_MODIFIER_REF)).replace(createObjectRef(task.getOwner(), prismContext))
.item(metadataPath.append(MetadataType.F_MODIFY_TASK_REF)).replaceRealValues(
task.getOid() != null ? singleton(createObjectRef(task.getTaskPrismObject(), prismContext)) : emptySet())
.asItemDeltas();
}
内容来源于网络,如有侵权,请联系作者删除!