}

    private void ensureIndexExists(final SearchEngineClient client, final String indexName) {
        if (!indexChecked) {
            if (!client.existsIndex(indexName)) {
                client.createIndex(NOTIFICATION_QUEUE_INDEX, indexName);
            }
            indexChecked = true;
        }
    }

                final String indexName;
                if (isFessIndex) {
                    final boolean exists = existsIndex(fessConfig.getIndexDocumentUpdateIndex());
                    if (!exists) {
                        indexName = generateNewIndexName(configIndex);
                        createIndex(configIndex, indexName);
                        createAlias(configIndex, indexName);
                    } else {

        @Override
        public boolean existsIndex(final String indexName) {
            calledMethods.add("existsIndex");
            if (useExistingIndicesSet) {
                return existingIndices.contains(indexName);
            }
            return existsIndexResult;
        }

        @Override
        public long getDocumentCount(final String indexName) {
            calledMethods.add("getDocumentCount");

            return "No notification targets configured.";
        }

        final SearchEngineClient client = ComponentUtil.getSearchEngineClient();
        final String indexName = fessConfig.getIndexLogIndex() + ".notification_queue";

        if (!client.existsIndex(indexName)) {
            return "No log notifications.";
        }

        final int searchSize = fessConfig.getLogNotificationSearchSizeAsInteger();

        ComponentUtil.register(new SystemHelper(), "systemHelper");
        ComponentUtil.register(new SearchEngineClient() {
            @Override
            public boolean existsIndex(final String indexName) {
                return false;
            }
        }, "searchEngineClient");

        String result = logNotificationJob.execute();
        assertEquals("No log notifications.", result);
    }

            }
        });
        // Verify that the index name pattern uses config prefix correctly
        final String indexName = coordinatorHelper.getIndexName();
        assertTrue(indexName.endsWith(".coordinator"));
        assertTrue(indexName.startsWith("fess_config"));
    }

    // ===================================================================================