@Test(groups = SMALL)
public void testWhenPollerStopsInvokesTheCleanupMethodOfTheEventSource() throws InterruptedException {

    startPollingThread();
    poller.stop();
    sleep(100L);
    verify(evtSource).cleanup();
}