}
        };

        helper.poll();
        assertTrue(heartbeatCalled.get());
        assertTrue(cleanupCalled.get());
    }

    @Test
    public void test_poll_dispatchesEvents() {
        // Verify that poll fetches events and dispatches them
        final AtomicInteger dispatchCount = new AtomicInteger(0);
        final CoordinatorHelper helper = new CoordinatorHelper() {