本文整理了Java中com.evolveum.midpoint.task.api.Task.refresh()
方法的一些代码示例,展示了Task.refresh()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.refresh()
方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称:Task
方法名:refresh
[英]Re-reads the task state from the persistent storage. The task state may be synchronized with the repository all the time. But the specified timing is implementation-specific. Call to this method will make sure that the task contains fresh data. This has no effect on transient tasks.
[中]从持久性存储器中重新读取任务状态。任务状态可能会一直与存储库同步。但指定的时间是特定于实现的。调用此方法将确保任务包含新数据。这对临时任务没有影响。
代码示例来源:origin: Evolveum/midpoint
@Override
public boolean check() throws CommonException {
task.refresh(waitResult);
waitResult.summarize();
// Task freshTask = taskManager.getTaskWithResult(task.getOid(), waitResult);
OperationResult result = task.getResult();
if (verbose) display("Check result", result);
assert !isError(result, checkSubresult) : "Error in "+task+": "+TestUtil.getErrorMessage(result);
assert !isUnknown(result, checkSubresult) : "Unknown result in "+task+": "+TestUtil.getErrorMessage(result);
return !isInProgress(result, checkSubresult);
}
@Override
代码示例来源:origin: Evolveum/midpoint
@Override
public void timeout() {
try {
task.refresh(waitResult);
} catch (ObjectNotFoundException e) {
LOGGER.error("Exception during task refresh: {}", e,e);
} catch (SchemaException e) {
LOGGER.error("Exception during task refresh: {}", e,e);
}
OperationResult result = task.getResult();
LOGGER.debug("Result of timed-out task:\n{}", result.debugDump());
assert false : "Timeout ("+timeout+") while waiting for "+task+" to finish. Last result "+result;
}
};
代码示例来源:origin: Evolveum/midpoint
@Override
public boolean check() throws CommonException {
task.refresh(waitResult);
OperationResult result = task.getResult();
if (verbose) display("Check result", result);
return task.getExecutionStatus() == TaskExecutionStatus.CLOSED;
}
@Override
代码示例来源:origin: Evolveum/midpoint
@Override
public boolean check() throws CommonException {
task.refresh(waitResult);
OperationResult result = task.getResult();
if (verbose)
display("Check result", result);
return task.getExecutionStatus() == TaskExecutionStatus.CLOSED;
}
代码示例来源:origin: Evolveum/midpoint
@Override
public void timeout() {
try {
task.refresh(waitResult);
} catch (Throwable e) {
display("Exception during task refresh", e);
}
OperationResult result = task.getResult();
display("Result of timed-out task", result);
assert false : "Timeout (" + timeout + ") while waiting for " + task + " to finish. Last result " + result;
}
};
代码示例来源:origin: Evolveum/midpoint
@Override
public boolean check() throws CommonException {
task.refresh(waitResult);
OperationResult result = task.getResult();
if (verbose) display("Check result", result);
return task.getExecutionStatus() == TaskExecutionStatus.CLOSED;
}
@Override
代码示例来源:origin: Evolveum/midpoint
@Override
public boolean check() throws CommonException {
syncCycle.refresh(result);
display("SyncCycle while waiting for sync cycle to detect change", syncCycle);
if (syncCycle.getExecutionStatus() != TaskExecutionStatus.RUNNABLE) {
throw new IllegalStateException("Task not runnable: "+syncCycle.getExecutionStatus()+"; "+syncCycle);
}
int tokenNow = findSyncToken(syncCycle);
display("tokenNow = " + tokenNow);
if (tokenNow >= tokenBefore + increment) {
return true;
} else {
return false;
}
}
代码示例来源:origin: Evolveum/midpoint
if (taskResult == null) {
try {
task.refresh(parentResult); // expecting to get the result
} catch (ObjectNotFoundException e) {
LOGGER.warn("Task result cannot be updated because the task is gone: {}", task, e);
代码示例来源:origin: Evolveum/midpoint
@Override
public void timeout() {
try {
task.refresh(waitResult);
} catch (ObjectNotFoundException e) {
LOGGER.error("Exception during task refresh: {}", e,e);
} catch (SchemaException e) {
LOGGER.error("Exception during task refresh: {}", e,e);
}
OperationResult result = task.getResult();
LOGGER.debug("Result of timed-out task:\n{}", result.debugDump());
assert false : "Timeout ("+timeout+") while waiting for "+task+" to finish. Last result "+result;
}
};
代码示例来源:origin: Evolveum/midpoint
@Override
public void timeout() {
try {
task.refresh(waitResult);
} catch (ObjectNotFoundException e) {
LOGGER.error("Exception during task refresh: {}", e,e);
} catch (SchemaException e) {
LOGGER.error("Exception during task refresh: {}", e,e);
}
OperationResult result = task.getResult();
LOGGER.debug("Result of timed-out task:\n{}", result.debugDump());
assert false : "Timeout ("+timeout+") while waiting for "+task+" to finish. Last result "+result;
}
};
代码示例来源:origin: Evolveum/midpoint
@Test
public void test100LightweightSubtasks() throws Exception {
final String TEST_NAME = "test100LightweightSubtasks";
final OperationResult result = createResult(TEST_NAME, LOGGER);
addObjectFromFile(taskFilename(TEST_NAME));
Task task = getTask(taskOid(TEST_NAME), result);
System.out.println("After setup: " + task.debugDump());
waitForTaskClose(taskOid(TEST_NAME), result, 15000, 500);
task.refresh(result);
System.out.println("After refresh (task was executed): " + task.debugDump());
Collection<? extends Task> subtasks = parallelTaskHandler.getLastTaskExecuted().getLightweightAsynchronousSubtasks();
assertEquals("Wrong number of subtasks", MockParallelTaskHandler.NUM_SUBTASKS, subtasks.size());
for (Task subtask : subtasks) {
assertEquals("Wrong subtask state", TaskExecutionStatus.CLOSED, subtask.getExecutionStatus());
MockParallelTaskHandler.MyLightweightTaskHandler handler = (MockParallelTaskHandler.MyLightweightTaskHandler) subtask.getLightweightTaskHandler();
assertTrue("Handler has not run", handler.hasRun());
assertTrue("Handler has not exited", handler.hasExited());
}
}
代码示例来源:origin: Evolveum/midpoint
task.refresh(result);
System.out.println("After initial wait: " + task.debugDump());
task.refresh(result);
System.out.println("After refresh: " + task.debugDump());
task.refresh(result);
AssertJUnit.assertTrue("Task is not stopped", stopped);
AssertJUnit.assertEquals("Task is not suspended", TaskExecutionStatus.SUSPENDED, task.getExecutionStatus());
代码示例来源:origin: Evolveum/midpoint
@Deprecated
@Test
public void test380DisableJackInBackgroundSimple() throws Exception {
final String TEST_NAME = "test380DisableJackInBackgroundSimple";
TestUtil.displayTestTitle(this, TEST_NAME);
// GIVEN
OperationResult result = new OperationResult(DOT_CLASS + TEST_NAME);
// WHEN
Task task = taskManager.createTaskInstance();
task.setOwner(getUser(USER_ADMINISTRATOR_OID));
scriptingExpressionEvaluator.evaluateExpressionInBackground(UserType.COMPLEX_TYPE,
ObjectQueryUtil.createOrigNameQuery("jack", prismContext).getFilter(),
"disable", task, result);
waitForTaskFinish(task.getOid(), false);
task.refresh(result);
// THEN
display(task.getResult());
TestUtil.assertSuccess(task.getResult());
PrismObject<UserType> jack = getUser(USER_JACK_OID);
display("jack after disable script", jack);
assertAdministrativeStatusDisabled(jack);
}
代码示例来源:origin: Evolveum/midpoint
task.refresh(result);
System.out.println("After refresh (task was started; and it should run now): " + task.debugDump());
task.refresh(result);
AssertJUnit.assertTrue("Task is not stopped", stopped);
AssertJUnit.assertEquals("Task is not suspended", TaskExecutionStatus.SUSPENDED, task.getExecutionStatus());
代码示例来源:origin: Evolveum/midpoint
task.refresh(result);
task.refresh(result);
task.refresh(result);
代码示例来源:origin: Evolveum/midpoint
@Test
public void test370AssignToJackInBackground() throws Exception {
final String TEST_NAME = "test370AssignToJackInBackground";
TestUtil.displayTestTitle(this, TEST_NAME);
// GIVEN
OperationResult result = new OperationResult(DOT_CLASS + TEST_NAME);
PrismProperty<ScriptingExpressionType> expression = parseAnyData(ASSIGN_TO_JACK_2_FILE);
// WHEN
Task task = taskManager.createTaskInstance();
task.setOwner(getUser(USER_ADMINISTRATOR_OID));
scriptingExpressionEvaluator.evaluateExpressionInBackground(expression.getAnyValue().getValue(), task, result);
waitForTaskFinish(task.getOid(), false);
task.refresh(result);
// THEN
display(task.getResult());
TestUtil.assertSuccess(task.getResult());
PrismObject<UserType> jack = getUser(USER_JACK_OID);
display("jack after assignment creation", jack);
assertAssignedRole(jack, "12345678-d34d-b33f-f00d-555555556677");
}
代码示例来源:origin: Evolveum/midpoint
task.refresh(result);
System.out.println("After suspend and refresh: " + task.debugDump());
代码示例来源:origin: Evolveum/midpoint
@Test
public void test507ScriptingUsersInBackgroundAssign() throws Exception {
final String TEST_NAME = "test507ScriptingUsersInBackgroundAssign";
TestUtil.displayTestTitle(this, TEST_NAME);
// GIVEN
Task task = createTask(DOT_CLASS + TEST_NAME);
task.setOwner(getUser(USER_ADMINISTRATOR_OID));
OperationResult result = task.getResult();
ExecuteScriptType exec = prismContext.parserFor(SCRIPTING_USERS_IN_BACKGROUND_ASSIGN_FILE).parseRealValue();
// WHEN
task.setExtensionPropertyValue(SchemaConstants.SE_EXECUTE_SCRIPT, exec);
task.setHandlerUri(ModelPublicConstants.SCRIPT_EXECUTION_TASK_HANDLER_URI);
dummyTransport.clearMessages();
boolean notificationsDisabled = notificationManager.isDisabled();
notificationManager.setDisabled(false);
taskManager.switchToBackground(task, result);
waitForTaskFinish(task.getOid(), false);
task.refresh(result);
// THEN
display(task.getResult());
TestUtil.assertSuccess(task.getResult());
PrismObject<UserType> admin = getUser(USER_ADMINISTRATOR_OID);
display("admin after operation", admin);
assertAssignedRole(admin, ROLE_EMPTY_OID);
display("dummy transport", dummyTransport);
notificationManager.setDisabled(notificationsDisabled);
assertEquals("Wrong # of messages in dummy transport", 1,
emptyIfNull(dummyTransport.getMessages("dummy:simpleUserNotifier")).size());
}
代码示例来源:origin: Evolveum/midpoint
@Test
public void test018TaskResult() throws Exception {
final String TEST_NAME = "test018RefreshingResult";
final OperationResult result = createResult(TEST_NAME, LOGGER);
Task task = taskManager.createTaskInstance();
task.setInitialExecutionStatus(TaskExecutionStatus.SUSPENDED);
PrismObject<UserType> owner2 = repositoryService.getObject(UserType.class, TASK_OWNER2_OID, null, result);
task.setOwner(owner2);
AssertJUnit.assertEquals("Task result for new task is not correct", OperationResultStatus.UNKNOWN, task.getResult().getStatus());
taskManager.switchToBackground(task, result);
AssertJUnit.assertEquals("Background task result is not correct (in memory)", OperationResultStatus.IN_PROGRESS, task.getResult().getStatus());
PrismObject<TaskType> task1 = repositoryService.getObject(TaskType.class, task.getOid(), retrieveItemsNamed(TaskType.F_RESULT), result);
AssertJUnit.assertEquals("Background task result is not correct (in repo)", OperationResultStatusType.IN_PROGRESS, task1.asObjectable().getResult().getStatus());
// now change task's result and check the refresh() method w.r.t. result handling
task.getResult().recordFatalError("");
AssertJUnit.assertEquals(OperationResultStatus.FATAL_ERROR, task.getResult().getStatus());
task.refresh(result);
AssertJUnit.assertEquals("Refresh does not update task's result", OperationResultStatus.IN_PROGRESS, task.getResult().getStatus());
}
代码示例来源:origin: Evolveum/midpoint
task.refresh(result);
内容来源于网络,如有侵权,请联系作者删除!