Class CmmnJobTestHelper

java.lang.Object
org.flowable.cmmn.engine.test.impl.CmmnJobTestHelper

public class CmmnJobTestHelper extends Object
Helper class for writing unit tests with the async executor. Inspired by the JobTestHelper from the bpmn engine, but adapted for cmmn.
Author:
Joram Barrez
  • Constructor Details

    • CmmnJobTestHelper

      public CmmnJobTestHelper()
  • Method Details

    • waitForJobExecutorToProcessAllJobs

      public static void waitForJobExecutorToProcessAllJobs(CmmnEngine cmmnEngine, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)
    • waitForJobExecutorToProcessAllJobs

      public static void waitForJobExecutorToProcessAllJobs(CmmnEngineConfiguration cmmnEngineConfiguration, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)
    • waitForJobExecutorToProcessAllAsyncJobs

      public static void waitForJobExecutorToProcessAllAsyncJobs(CmmnEngineConfiguration cmmnEngineConfiguration, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)
    • waitForJobExecutorOnCondition

      public static void waitForJobExecutorOnCondition(CmmnEngineConfiguration cmmnEngineConfiguration, long maxMillisToWait, long intervalMillis, Callable<Boolean> predicate)
    • waitForAsyncHistoryExecutorToProcessAllJobs

      public static void waitForAsyncHistoryExecutorToProcessAllJobs(CmmnEngineConfiguration cmmnEngineConfiguration, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)
    • executeJobExecutorForTime

      public static void executeJobExecutorForTime(CmmnEngineConfiguration cmmnEngineConfiguration, long maxMillisToWait, long intervalMillis)
    • waitForExecutorToProcessAllJobs

      public static void waitForExecutorToProcessAllJobs(AsyncExecutor asyncExecutor, Callable<Boolean> callable, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)
    • areJobsAvailable

      public static boolean areJobsAvailable(CmmnManagementService managementService)