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

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