Package org.opendaylight.genius.datastoreutils.testutils

Class TestableJobCoordinatorCountedEventsWaiter

java.lang.Object

org.opendaylight.genius.datastoreutils.testutils.AbstractTestableJobCoordinatorEventsWaiter

org.opendaylight.genius.datastoreutils.testutils.TestableJobCoordinatorCountedEventsWaiter

All Implemented Interfaces:

JobCoordinatorCountedEventsWaiter

@Singleton
public class TestableJobCoordinatorCountedEventsWaiter
extends AbstractTestableJobCoordinatorEventsWaiter
implements JobCoordinatorCountedEventsWaiter

Field Summary

Fields inherited from class org.opendaylight.genius.datastoreutils.testutils.AbstractTestableJobCoordinatorEventsWaiter

jobCoordinatorMonitor

Constructor Summary

Constructors

Constructor	Description
TestableJobCoordinatorCountedEventsWaiter(org.opendaylight.infrautils.jobcoordinator.JobCoordinatorMonitor jobCoordinatorMonitor)

Method Summary

Modifier and Type	Method	Description
boolean	awaitJobsConsumption(long newAdditionalClearedJobCountSinceLastCall)	Wait by blocking calling thread until an expected number of jobs have been processed by job coordinator.

Methods inherited from class org.opendaylight.genius.datastoreutils.testutils.AbstractTestableJobCoordinatorEventsWaiter

awaitJobsConsumption

Methods inherited from class java.lang.Object

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

Constructor Detail

TestableJobCoordinatorCountedEventsWaiter

@Inject
public TestableJobCoordinatorCountedEventsWaiter(org.opendaylight.infrautils.jobcoordinator.JobCoordinatorMonitor jobCoordinatorMonitor)

Method Detail

awaitJobsConsumption

public boolean awaitJobsConsumption(long newAdditionalClearedJobCountSinceLastCall)
                             throws org.awaitility.core.ConditionTimeoutException

Description copied from interface: JobCoordinatorCountedEventsWaiter

Wait by blocking calling thread until an expected number of jobs have been processed by job coordinator. Implementations must have some sensible fixed timeout value. This method is normally called from the JUnit Test main thread.

Specified by:

awaitJobsConsumption in interface JobCoordinatorCountedEventsWaiter

Returns:

true if all the expected number of jobs have been processed, false otherwise

Throws:

org.awaitility.core.ConditionTimeoutException - if timed out while waiting