Package org.opendaylight.genius.datastoreutils.testutils

Class TestableJobCoordinatorEventsWaiter

java.lang.Object

org.opendaylight.genius.datastoreutils.testutils.AbstractTestableJobCoordinatorEventsWaiter

org.opendaylight.genius.datastoreutils.testutils.TestableJobCoordinatorEventsWaiter

All Implemented Interfaces:

java.lang.AutoCloseable, AsyncEventsWaiter, JobCoordinatorEventsWaiter

@Singleton
public class TestableJobCoordinatorEventsWaiter
extends AbstractTestableJobCoordinatorEventsWaiter
implements JobCoordinatorEventsWaiter

Field Summary

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

jobCoordinatorMonitor

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	awaitEventsConsumption()	Wait by blocking calling thread until pending events have been processed by other threads in the background.
void	close()

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

TestableJobCoordinatorEventsWaiter

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

Method Detail

awaitEventsConsumption

public boolean awaitEventsConsumption()
                               throws org.awaitility.core.ConditionTimeoutException

Description copied from interface: AsyncEventsWaiter

Wait by blocking calling thread until pending events have been processed by other threads in the background. Implementations must have some sensible fixed timeout value. This method is normally called from the JUnit Test main thread.

Specified by:

awaitEventsConsumption in interface AsyncEventsWaiter

Returns:

true if anything was pending to be processed and has been processed, false if nothing needed to be

Throws:

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

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception