}

                    updateTime = systemHelper.getCurrentTimeAsLong();

                    List<OpenSearchAccessResult> arList = getAccessResultList(cb, cleanupTime);
                    if (arList.isEmpty()) {
                        emptyListCount++;
                    } else {
                        emptyListCount = 0; // reset
                    }

        private boolean throwContainerNotAvailable = false;
        private boolean throwRuntimeException = false;

        @Override
        public List<OpenSearchAccessResult> getAccessResultList(Consumer<SearchRequestBuilder> cb) {
            if (throwContainerNotAvailable) {
                throw new ContainerNotAvailableException("");
            }
            if (throwRuntimeException) {