Package org.flowable.engine.impl.test

Class JobTestHelper

java.lang.Object

org.flowable.engine.impl.test.JobTestHelper

public class JobTestHelper
extends Object

Author:

Joram Barrez, Tijs Rademakers, Saeid Mirzaei

Constructor Summary

Constructors

Constructor	Description
JobTestHelper()

Method Summary

Modifier and Type	Method	Description
static boolean	areJobsAvailable(ManagementService managementService)
static boolean	areJobsAvailable(FlowableRule activitiRule)
static boolean	areJobsOrExecutableTimersAvailable(ManagementService managementService)
static boolean	areJobsOrTimersAvailable(ManagementService managementService)	Returns true when there are any entries for the jobs or timers (unlike areJobsOrExecutableTimersAvailable(ManagementService), which only take in account executable timers).
static void	executeJobExecutorForTime(ProcessEngineConfiguration processEngineConfiguration, long maxMillisToWait, long intervalMillis)
static void	executeJobExecutorForTime(FlowableRule activitiRule, long maxMillisToWait, long intervalMillis)
protected static void	internalWaitForJobs(ProcessEngineConfiguration processEngineConfiguration, ManagementService managementService, Predicate<ManagementService> jobsAvailablePredicate, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)
static void	waitForJobExecutorOnCondition(ProcessEngineConfiguration processEngineConfiguration, long maxMillisToWait, long intervalMillis, Callable<Boolean> condition)
static void	waitForJobExecutorOnCondition(FlowableRule activitiRule, long maxMillisToWait, long intervalMillis, Callable<Boolean> condition)
static void	waitForJobExecutorToProcessAllJobs(ProcessEngineConfiguration processEngineConfiguration, ManagementService managementService, long maxMillisToWait, long intervalMillis)
static void	waitForJobExecutorToProcessAllJobs(ProcessEngineConfiguration processEngineConfiguration, ManagementService managementService, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)
static void	waitForJobExecutorToProcessAllJobs(FlowableRule rule, long maxMillisToWait, long intervalMillis)
static void	waitForJobExecutorToProcessAllJobsAndExecutableTimerJobs(ProcessEngineConfiguration processEngineConfiguration, ManagementService managementService, long maxMillisToWait, long intervalMillis)
static void	waitForJobExecutorToProcessAllJobsAndExecutableTimerJobs(ProcessEngineConfiguration processEngineConfiguration, ManagementService managementService, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)
static void	waitForJobExecutorToProcessAllJobsAndTimerJobs(ProcessEngineConfiguration processEngineConfiguration, ManagementService managementService, long maxMillisToWait, long intervalMillis)
static void	waitForJobExecutorToProcessAllJobsAndTimerJobs(ProcessEngineConfiguration processEngineConfiguration, ManagementService managementService, long maxMillisToWait, long intervalMillis, boolean shutdownExecutorWhenFinished)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JobTestHelper

public JobTestHelper()

Method Details

waitForJobExecutorToProcessAllJobs

public static void waitForJobExecutorToProcessAllJobs(FlowableRule rule,
 long maxMillisToWait,
 long intervalMillis)

waitForJobExecutorToProcessAllJobs

public static void waitForJobExecutorToProcessAllJobs(ProcessEngineConfiguration processEngineConfiguration,
 ManagementService managementService,
 long maxMillisToWait,
 long intervalMillis)

waitForJobExecutorToProcessAllJobs

public static void waitForJobExecutorToProcessAllJobs(ProcessEngineConfiguration processEngineConfiguration,
 ManagementService managementService,
 long maxMillisToWait,
 long intervalMillis,
 boolean shutdownExecutorWhenFinished)

waitForJobExecutorToProcessAllJobsAndExecutableTimerJobs

public static void waitForJobExecutorToProcessAllJobsAndExecutableTimerJobs(ProcessEngineConfiguration processEngineConfiguration,
 ManagementService managementService,
 long maxMillisToWait,
 long intervalMillis)

waitForJobExecutorToProcessAllJobsAndExecutableTimerJobs

public static void waitForJobExecutorToProcessAllJobsAndExecutableTimerJobs(ProcessEngineConfiguration processEngineConfiguration,
 ManagementService managementService,
 long maxMillisToWait,
 long intervalMillis,
 boolean shutdownExecutorWhenFinished)

waitForJobExecutorToProcessAllJobsAndTimerJobs

public static void waitForJobExecutorToProcessAllJobsAndTimerJobs(ProcessEngineConfiguration processEngineConfiguration,
 ManagementService managementService,
 long maxMillisToWait,
 long intervalMillis)

waitForJobExecutorToProcessAllJobsAndTimerJobs

public static void waitForJobExecutorToProcessAllJobsAndTimerJobs(ProcessEngineConfiguration processEngineConfiguration,
 ManagementService managementService,
 long maxMillisToWait,
 long intervalMillis,
 boolean shutdownExecutorWhenFinished)

waitForJobExecutorOnCondition

public static void waitForJobExecutorOnCondition(FlowableRule activitiRule,
 long maxMillisToWait,
 long intervalMillis,
 Callable<Boolean> condition)

waitForJobExecutorOnCondition

public static void waitForJobExecutorOnCondition(ProcessEngineConfiguration processEngineConfiguration,
 long maxMillisToWait,
 long intervalMillis,
 Callable<Boolean> condition)

executeJobExecutorForTime

public static void executeJobExecutorForTime(FlowableRule activitiRule,
 long maxMillisToWait,
 long intervalMillis)

executeJobExecutorForTime

public static void executeJobExecutorForTime(ProcessEngineConfiguration processEngineConfiguration,
 long maxMillisToWait,
 long intervalMillis)

areJobsAvailable

public static boolean areJobsAvailable(FlowableRule activitiRule)

areJobsAvailable

public static boolean areJobsAvailable(ManagementService managementService)

areJobsOrExecutableTimersAvailable

public static boolean areJobsOrExecutableTimersAvailable(ManagementService managementService)

areJobsOrTimersAvailable

public static boolean areJobsOrTimersAvailable(ManagementService managementService)

Returns true when there are any entries for the jobs or timers (unlike areJobsOrExecutableTimersAvailable(ManagementService), which only take in account executable timers).

internalWaitForJobs

protected static void internalWaitForJobs(ProcessEngineConfiguration processEngineConfiguration,
 ManagementService managementService,
 Predicate<ManagementService> jobsAvailablePredicate,
 long maxMillisToWait,
 long intervalMillis,
 boolean shutdownExecutorWhenFinished)