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

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

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

Task.getTaskType介绍

暂无

代码示例

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

public WorkflowProcessEvent(LightweightIdentifierGenerator lightweightIdentifierGenerator, ChangeType changeType, Task wfTask) {
  super(lightweightIdentifierGenerator, changeType, wfTask.getWorkflowContext(), wfTask.getTaskType(), null);
}

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

private void onWorkItemAllocationModifyDelete(ObjectReferenceType currentActor, @NotNull WorkItemType workItem,
    @Nullable WorkItemOperationInfo operationInfo, @Nullable WorkItemOperationSourceInfo sourceInfo,
    Duration timeBefore, Task task, OperationResult result) {
  WorkItemAllocationEvent event = new WorkItemAllocationEvent(identifierGenerator,
      timeBefore != null ? ChangeType.MODIFY : ChangeType.DELETE, workItem,
      SimpleObjectRefImpl.create(functions, currentActor),
      getInitiator(sourceInfo), operationInfo, sourceInfo,
      task.getWorkflowContext(), task.getTaskType(), timeBefore);
  initializeWorkflowEvent(event, task);
  processEvent(event, result);
}
//endregion

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

private boolean isStopOnError(Task task, Throwable ex, OperationResult result) throws ObjectNotFoundException, CommunicationException, SchemaException, ConfigurationException, SecurityViolationException, PolicyViolationException, ExpressionEvaluationException, ObjectAlreadyExistsException, PreconditionViolationException {
  if (stageType == null) {
    return stopOnError;
  }
  
  CriticalityType criticality = ExceptionUtil.getCriticality(stageType.getErrorCriticality(), ex, CriticalityType.PARTIAL);
  RepoCommonUtils.processErrorCriticality(task.getTaskType(), criticality, ex, result);
  
  return stopOnError;
}

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

private void onWorkItemAllocationAdd(ObjectReferenceType newActor, @NotNull WorkItemType workItem,
    @Nullable WorkItemOperationInfo operationInfo, @Nullable WorkItemOperationSourceInfo sourceInfo,
    Task task, OperationResult result) {
  WorkItemAllocationEvent event = new WorkItemAllocationEvent(identifierGenerator, ChangeType.ADD, workItem,
      SimpleObjectRefImpl.create(functions, newActor),
      getInitiator(sourceInfo), operationInfo, sourceInfo,
      task.getWorkflowContext(), task.getTaskType(), null);
  initializeWorkflowEvent(event, task);
  processEvent(event, result);
}

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

private WorkBucketType findSelfAllocatedBucket(Context ctx) {
  TaskWorkStateType workState = ctx.workerTask.getTaskType().getWorkState();
  if (workState == null || workState.getBucket().isEmpty()) {
    return null;
  }
  List<WorkBucketType> buckets = new ArrayList<>(workState.getBucket());
  TaskWorkStateTypeUtil.sortBucketsBySequentialNumber(buckets);
  for (WorkBucketType bucket : buckets) {
    if (bucket.getState() == WorkBucketStateType.READY) {
      return bucket;
    }
  }
  return null;
}

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

@Override
public void onWorkItemCreation(ObjectReferenceType assignee, @NotNull WorkItemType workItem,
    Task wfTask, OperationResult result) {
  WorkItemEvent event = new WorkItemLifecycleEvent(identifierGenerator, ChangeType.ADD, workItem,
      SimpleObjectRefImpl.create(functions, assignee), null, null, null,
      wfTask.getWorkflowContext(), wfTask.getTaskType());
  initializeWorkflowEvent(event, wfTask);
  processEvent(event, result);
}

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

@Override
public void onWorkItemDeletion(ObjectReferenceType assignee, @NotNull WorkItemType workItem,
    WorkItemOperationInfo operationInfo, WorkItemOperationSourceInfo sourceInfo,
    Task wfTask, OperationResult result) {
  WorkItemEvent event = new WorkItemLifecycleEvent(identifierGenerator, ChangeType.DELETE, workItem,
      SimpleObjectRefImpl.create(functions, assignee),
      getInitiator(sourceInfo), operationInfo, sourceInfo, wfTask.getWorkflowContext(), wfTask.getTaskType());
  initializeWorkflowEvent(event, wfTask);
  processEvent(event, result);
}

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

@Override
public void onWorkItemCustomEvent(ObjectReferenceType assignee, @NotNull WorkItemType workItem,
    @NotNull WorkItemNotificationActionType notificationAction, WorkItemEventCauseInformationType cause, Task wfTask,
    OperationResult result) {
  WorkItemEvent event = new WorkItemCustomEvent(identifierGenerator, ChangeType.ADD, workItem,
      SimpleObjectRefImpl.create(functions, assignee),
      new WorkItemOperationSourceInfo(null, cause, notificationAction),
      wfTask.getWorkflowContext(), wfTask.getTaskType(), notificationAction.getHandler());
  initializeWorkflowEvent(event, wfTask);
  processEvent(event, result);
}

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

private boolean performResourceReconciliation(PrismObject<ResourceType> resource,
    ObjectClassComplexTypeDefinition objectclassDef,
    ReconciliationTaskResult reconResult, Task localCoordinatorTask,
    WorkBucketType workBucket, OperationResult result)
    throws ObjectNotFoundException, SchemaException, CommunicationException, ConfigurationException,
    SecurityViolationException, ExpressionEvaluationException {

  List<TaskStageType> stages = localCoordinatorTask.getTaskType().getStage();
  if (CollectionUtils.isEmpty(stages)) {
    TaskStageType defaultStage = new TaskStageType(prismContext);
    defaultStage.setStage(EXECUTE_URI);
    return performResourceReconciliationInternal(resource, objectclassDef, defaultStage, 
        reconResult, localCoordinatorTask, workBucket, result);
  }
  
  boolean canContinue = true;
  for (TaskStageType stage : stages) {
    canContinue = performResourceReconciliationInternal(resource, objectclassDef, stage, 
        reconResult, localCoordinatorTask, workBucket, result);
    if (!canContinue) {
      break;
    }
  }
  
  return canContinue;

}

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

@Override
protected void assertFinishedPropagationTask(Task finishedTask, OperationResultStatusType expectedStatus) {
  super.assertFinishedPropagationTask(finishedTask, expectedStatus);
  SearchFilterType filterType = finishedTask.getTaskType().getObjectRef().getFilter();
  display("Propagation task filter", filterType);
  
  assertEquals("Unexpected propagation task progress", 1, finishedTask.getProgress());
}

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

Collection<AssignmentType> taskAssignments = ctx.task.getTaskType().getAssignment();
for (AssignmentType taskAssignment : taskAssignments) {
  try {

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

prismContext, task, result);
TaskType taskType = task.getTaskType();
LOGGER.info("Task for process: {}", taskType.asPrismObject().debugDump());
AssignmentType taskAssignment = null;

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

TaskType coordinatorTaskBean = coordinatorTask.getTaskType();
TaskWorkManagementType wsCfg = coordinatorTask.getWorkManagement();
WorkersManagementType workersCfg = wsCfg.getWorkers();

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

TaskType masterTaskBean = masterTask.getTaskType();
TaskType subtask = new TaskType(getPrismContext());

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

assertNumericBucket(bucket4, null, 4, 3, 4);
assertNumericBucket(bucket4a, null, 4, 3, 4);
List<WorkBucketType> buckets = new ArrayList<>(coordinator.getTaskType().getWorkState().getBucket());
sortBucketsBySequentialNumber(buckets);
assertEquals(5, buckets.size());
display("coordinator after completion of 2nd bucket", coordinator);
buckets = new ArrayList<>(coordinator.getTaskType().getWorkState().getBucket());
sortBucketsBySequentialNumber(buckets);
display("coordinator after releasing of 4th bucket", coordinator);
buckets = new ArrayList<>(coordinator.getTaskType().getWorkState().getBucket());
sortBucketsBySequentialNumber(buckets);
buckets = new ArrayList<>(coordinator.getTaskType().getWorkState().getBucket());
assertEquals(2, buckets.size());
assertNumericBucket(buckets.get(0), WorkBucketStateType.DELEGATED, 4, 3, 4);
buckets = new ArrayList<>(coordinator.getTaskType().getWorkState().getBucket());
assertEquals(2, buckets.size());
assertNumericBucket(buckets.get(0), WorkBucketStateType.DELEGATED, 4, 3, 4);
buckets = new ArrayList<>(coordinator.getTaskType().getWorkState().getBucket());
assertEquals(1, buckets.size());
assertNumericBucket(buckets.get(0), WorkBucketStateType.COMPLETE, 5, 4, 5);

相关文章