*/
    public void addEventHandler(final String eventName, final Consumer<EventInfo> handler) {
        eventHandlers.computeIfAbsent(eventName, k -> new ArrayList<>()).add(handler);
    }

    /**
     * Fetches new events from OpenSearch that were created after the last check time.
     *
     * @return the list of new events.
     */
    protected List<EventInfo> fetchNewEvents() {

        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() {
            @Override