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

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