Package org.operaton.bpm.engine.test.util

Class JobExecutorAssert

java.lang.Object

org.operaton.bpm.engine.test.util.JobExecutorAssert

public final class JobExecutorAssert
extends Object

Fluent assertion to wait for the JobExecutor to process jobs.

Defaults are aligned with JobExecutorWaitUtils so existing behaviour can be used in a more expressive way.

Method Summary

Modifier and Type	Method	Description
static JobExecutorAssert	assertThatJobExecutor()
void	hasAllJobsProcessed()
protected void	resolveMissingConfiguration()
JobExecutorAssert	shutdownExecutorAfter(boolean shutdown)
JobExecutorAssert	withCheckInterval(long checkIntervalMillis)
JobExecutorAssert	withJobExecutor(JobExecutor jobExecutor)
JobExecutorAssert	withManagementService(ManagementService managementService)
JobExecutorAssert	withProcessEngine(ProcessEngine processEngine)
JobExecutorAssert	withProcessEngineConfiguration(ProcessEngineConfiguration configuration)
JobExecutorAssert	withProcessInstance(String processInstanceId)
JobExecutorAssert	withTimeout(long timeoutMillis)

Methods inherited from class java.lang.Object

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

Method Details

assertThatJobExecutor

public static JobExecutorAssert assertThatJobExecutor()

withProcessEngine

public JobExecutorAssert withProcessEngine(ProcessEngine processEngine)

withProcessEngineConfiguration

public JobExecutorAssert withProcessEngineConfiguration(ProcessEngineConfiguration configuration)

withJobExecutor

public JobExecutorAssert withJobExecutor(JobExecutor jobExecutor)

withManagementService

public JobExecutorAssert withManagementService(ManagementService managementService)

withProcessInstance

public JobExecutorAssert withProcessInstance(String processInstanceId)

withTimeout

public JobExecutorAssert withTimeout(long timeoutMillis)

withCheckInterval

public JobExecutorAssert withCheckInterval(long checkIntervalMillis)

shutdownExecutorAfter

public JobExecutorAssert shutdownExecutorAfter(boolean shutdown)

hasAllJobsProcessed

public void hasAllJobsProcessed()

resolveMissingConfiguration

protected void resolveMissingConfiguration()