private synchronized void updateIndex(final List<EntityEvent> events) {
        if (NullSafe.hasItems(events)) {
            final Map<EntityAction, Long> countsByAction = events.stream()
                    .collect(Collectors.groupingBy(EntityEvent::getAction, Collectors.counting()));

            LOGGER.logDurationIfDebugEnabled(
                    () -> {
                        securityContext.asProcessingUser(() -> {
                            updateIndex(events, taskContextFactory.current());
                        });
                    },
                    () -> LogUtil.message("Process {} content index events, counts by event type: ({})",
                            events.size(),
                            countsByAction.entrySet()
                                    .stream()
                                    .map(entry -> entry.getKey() + "=" + entry.getValue())
                                    .collect(Collectors.joining(", "))));
        }
    }
Re-index all indexable items on the system
stroom-index/stroom-index-lucene980/src/main/java/stroom/contentindex/LuceneContentIndex.java