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

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

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

Task.getLastRunStartTimestamp介绍

[英]Returns the time when the task last run was started (or null if the task was never started).
[中]返回任务上次运行的启动时间(如果任务从未启动,则返回null)。

代码示例

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

@Override
      public boolean check() throws CommonException {
        Task freshTask = taskManager.getTaskWithResult(origTask.getOid(), waitResult);
        OperationResult taskResult = freshTask.getResult();
//                display("Times", longTimeToString(origLastRunStartTimestamp) + "-" + longTimeToString(origLastRunStartTimestamp)
//                        + " : " + longTimeToString(freshTask.getLastRunStartTimestamp()) + "-" + longTimeToString(freshTask.getLastRunFinishTimestamp()));
        if (verbose) display("Check result", taskResult);
        taskResultHolder.setValue(taskResult);
        if (isError(taskResult, checkSubresult)) {
          return true;
        }
        if (isUnknown(taskResult, checkSubresult)) {
          return false;
        }
        if (freshTask.getLastRunFinishTimestamp() == null) {
          return false;
        }
        if (freshTask.getLastRunStartTimestamp() == null) {
          return false;
        }
        return !freshTask.getLastRunStartTimestamp().equals(origLastRunStartTimestamp)
            && !freshTask.getLastRunFinishTimestamp().equals(origLastRunFinishTimestamp)
            && freshTask.getLastRunStartTimestamp() < freshTask.getLastRunFinishTimestamp();
      }
      @Override

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

@Override
public boolean check() throws CommonException {
  Task freshTask = taskManager.getTaskWithResult(taskOid, waitResult);
  OperationResult result = freshTask.getResult();
  if (verbose) display("Check result", result);
  assert !isError(result, checkSubresult) : "Error in "+freshTask+": "+TestUtil.getErrorMessage(result);
  if (isUnknown(result, checkSubresult)) {
    return false;
  }
  return freshTask.getLastRunStartTimestamp() != null;
}
@Override

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

protected void waitForTaskStart(String oid, OperationResult result, long timeoutInterval, long sleepInterval) throws CommonException {
    waitFor("Waiting for task manager to start the task", () -> {
      Task task = taskManager.getTaskWithResult(oid, result);
      IntegrationTestTools.display("Task while waiting for task manager to start the task", task);
      return task.getLastRunStartTimestamp() != null && task.getLastRunStartTimestamp() != 0L;
    }, timeoutInterval, sleepInterval);
  }

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

protected void waitForTaskNextRun(String taskOid, OperationResult result, long timeoutInterval, long sleepInterval) throws Exception {
  TaskQuartzImpl taskBefore = (TaskQuartzImpl) taskManager.getTaskWithResult(taskOid, result);
  waitFor("Waiting for task manager to execute the task", () -> {
    Task task = taskManager.getTaskWithResult(taskOid, result);
    IntegrationTestTools.display("Task while waiting for task manager to execute the task", task);
    return task.getLastRunStartTimestamp() != null &&
        (taskBefore.getLastRunStartTimestamp() == null || task.getLastRunStartTimestamp() > taskBefore.getLastRunStartTimestamp());
  }, timeoutInterval, sleepInterval);
}

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

@Override
  public void timeout() {
    try {
      Task freshTask = taskManager.getTaskWithResult(origTask.getOid(), waitResult);
      OperationResult result = freshTask.getResult();
      LOGGER.debug("Timed-out task:\n{}", freshTask.debugDump());
      display("Times", "origLastRunStartTimestamp="+longTimeToString(origLastRunStartTimestamp)
      + ", origLastRunFinishTimestamp=" + longTimeToString(origLastRunFinishTimestamp)
      + ", freshTask.getLastRunStartTimestamp()=" + longTimeToString(freshTask.getLastRunStartTimestamp())
      + ", freshTask.getLastRunFinishTimestamp()=" + longTimeToString(freshTask.getLastRunFinishTimestamp()));
      assert false : "Timeout ("+timeout+") while waiting for "+freshTask+" next run. Last result "+result;
    } catch (ObjectNotFoundException | SchemaException e) {
      LOGGER.error("Exception during task refresh: {}", e, e);
    }
  }
};

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

protected OperationResult waitForTaskTreeNextFinishedRun(Task origRootTask, int timeout, OperationResult waitResult) throws Exception {
  Long origLastRunStartTimestamp = origRootTask.getLastRunStartTimestamp();
  Long origLastRunFinishTimestamp = origRootTask.getLastRunFinishTimestamp();
  long start = System.currentTimeMillis();
            + waiting + "]";
    if (!triggered.getValue() && (freshRootTask.getLastRunStartTimestamp() == null
        || freshRootTask.getLastRunStartTimestamp().equals(origLastRunStartTimestamp)
        || freshRootTask.getLastRunFinishTimestamp() == null
        || freshRootTask.getLastRunFinishTimestamp().equals(origLastRunFinishTimestamp)
        || freshRootTask.getLastRunStartTimestamp() >= freshRootTask.getLastRunFinishTimestamp())) {
      display("Root (triggering) task next run has not been completed yet: " + description);
      return false;

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

AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
assertFalse(task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
assertFalse(task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNull(task.getLastRunFinishTimestamp());
AssertJUnit.assertEquals("There should be no progress reported", 0, task.getProgress());
AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
assertFalse(task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull("Last run finish time is null", task.getLastRunStartTimestamp());
assertFalse("Last run finish time is zero", task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertTrue("Progress is not reported", task.getProgress() > 0);

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

protected OperationResult waitForTaskNextRun(final Task origTask, final boolean checkSubresult, final int timeout, final OperationResult waitResult, boolean kickTheTask) throws Exception {
  final Long origLastRunStartTimestamp = origTask.getLastRunStartTimestamp();
  final Long origLastRunFinishTimestamp = origTask.getLastRunFinishTimestamp();
  if (kickTheTask) {
  display("Times", "origLastRunStartTimestamp="+longTimeToString(origLastRunStartTimestamp)
  + ", origLastRunFinishTimestamp=" + longTimeToString(origLastRunFinishTimestamp)
  + ", freshTask.getLastRunStartTimestamp()=" + longTimeToString(freshTask.getLastRunStartTimestamp())
  + ", freshTask.getLastRunFinishTimestamp()=" + longTimeToString(freshTask.getLastRunFinishTimestamp()));

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

assertNull("task was started", task.getLastRunStartTimestamp());
assertEquals("task was achieved some progress", 0L, task.getProgress());
AssertJUnit.assertNotNull("LastRunStartTimestamp is null", task.getLastRunStartTimestamp());
assertFalse("LastRunStartTimestamp is 0", task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
assertFalse(task.getLastRunFinishTimestamp() == 0);

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

@Test
public void test010CycleCronLoose() throws Exception {
  final String TEST_NAME = "test010CycleCronLoose";
  final OperationResult result = createResult(TEST_NAME, LOGGER);
  addObjectFromFile(taskFilename(TEST_NAME));
  waitForTaskProgress(taskOid(TEST_NAME), result, 15000, 2000, 2);
  // Check task status
  Task task = getTask(taskOid(TEST_NAME), result);
  AssertJUnit.assertNotNull(task);
  System.out.println(task.debugDump());
  TaskType t = repositoryService.getObject(TaskType.class, taskOid(TEST_NAME), null, result).getValue().getValue();
  System.out.println(ObjectTypeUtil.dump(t));
  AssertJUnit.assertEquals(TaskExecutionStatus.RUNNABLE, task.getExecutionStatus());
  // .. and last run should not be zero
  AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
  assertFalse(task.getLastRunStartTimestamp() == 0);
  AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
  assertFalse(task.getLastRunFinishTimestamp() == 0);
  // The progress should be at least 2 as the task has run at least twice
  AssertJUnit.assertTrue("Task has not been executed at least twice", task.getProgress() >= 2);
  // Test for presence of a result. It should be there and it should
  // indicate success
  assertSuccessOrInProgress(task);
  // Suspend the task (in order to keep logs clean), without much waiting
  taskManager.suspendTaskQuietly(task, 100, result);
}

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

AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
assertFalse(task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
assertFalse(task.getLastRunFinishTimestamp() == 0);

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

AssertJUnit.assertEquals("Task is not suspended", TaskExecutionStatus.SUSPENDED, task.getExecutionStatus());
AssertJUnit.assertNotNull("Task last start time is null", task.getLastRunStartTimestamp());
assertFalse("Task last start time is 0", task.getLastRunStartTimestamp() == 0);

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

AssertJUnit.assertNotNull("LastRunStartTimestamp is null", task.getLastRunStartTimestamp());
assertFalse("LastRunStartTimestamp is 0", task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
assertFalse(task.getLastRunFinishTimestamp() == 0);
AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
assertFalse(task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
assertFalse(task.getLastRunFinishTimestamp() == 0);

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

AssertJUnit.assertNotNull("LastRunStartTimestamp is null", task1.getLastRunStartTimestamp());
assertFalse("LastRunStartTimestamp is 0", task1.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull("LastRunFinishTimestamp is null", task1.getLastRunFinishTimestamp());
assertFalse("LastRunFinishTimestamp is 0", task1.getLastRunFinishTimestamp() == 0);

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

AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
assertFalse(task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull("Last run finish timestamp not set", task.getLastRunFinishTimestamp());
assertFalse("Last run finish timestamp is 0", task.getLastRunFinishTimestamp() == 0);

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

AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
assertFalse(task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull("Last run finish timestamp not set", task.getLastRunFinishTimestamp());
assertFalse("Last run finish timestamp is 0", task.getLastRunFinishTimestamp() == 0);

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

AssertJUnit.assertNotNull("LastRunStartTimestamp is null", task.getLastRunStartTimestamp());
assertFalse("LastRunStartTimestamp is 0", task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull("LastRunFinishTimestamp is null", task.getLastRunFinishTimestamp());
assertFalse("LastRunFinishTimestamp is 0", task.getLastRunFinishTimestamp() == 0);

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

assertNotNull("No lastRunStartTimestamp", task.getLastRunStartTimestamp());
assertFalse("Zero lastRunStartTimestamp", task.getLastRunStartTimestamp().longValue() == 0);
assertNotNull("No lastRunFinishedTimestamp", task.getLastRunFinishTimestamp());
assertFalse("Zero lastRunFinishedTimestamp", task.getLastRunFinishTimestamp().longValue() == 0);

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

AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
assertFalse(task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull("Last run finish timestamp not set", task.getLastRunFinishTimestamp());
assertFalse("Last run finish timestamp is 0", task.getLastRunFinishTimestamp() == 0);

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

assertNotNull(task.getLastRunStartTimestamp());
AssertJUnit.assertFalse(task.getLastRunStartTimestamp().longValue() == 0);
assertNotNull(task.getLastRunFinishTimestamp());
AssertJUnit.assertFalse(task.getLastRunFinishTimestamp().longValue() == 0);

相关文章

微信公众号

最新文章

更多