}

        try {
            final List<EventInfo> events = fetchNewEvents();
            for (final EventInfo event : events) {
                dispatchEvent(event);
            }
        } catch (final Exception e) {
            logger.debug("Failed to process events in poll.", e);
        }

        try {
            cleanupExpiredDocuments();

        configEvent.name = "config_updated";
        coordinatorHelper.dispatchEvent(configEvent);
        assertEquals("config", received.get());

        final EventInfo dictEvent = new EventInfo();
        dictEvent.name = "dict_updated";
        coordinatorHelper.dispatchEvent(dictEvent);
        assertEquals("dict", received.get());
    }

    @Test