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