org.opendaylight.genius.datastoreutils.testutils

Class TestableJobCoordinatorEventsWaiter

java.lang.Object

org.opendaylight.genius.datastoreutils.testutils.TestableJobCoordinatorEventsWaiter

All Implemented Interfaces:

AutoCloseable, AsyncEventsWaiter, JobCoordinatorEventsWaiter

@Singleton
public class TestableJobCoordinatorEventsWaiter
extends Object
implements JobCoordinatorEventsWaiter

Constructor Summary

Constructors

Constructor and Description
TestableJobCoordinatorEventsWaiter(org.opendaylight.infrautils.jobcoordinator.JobCoordinatorMonitor coordinatorMonitor)

Method Summary

Modifier and Type	Method and 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 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 coordinatorMonitor)

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 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 Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception