if c.before != "" { // if defined before callback
			if c.before == "*" && len(sorted) > 0 {
				if curIdx := getRIndex(sorted, c.name); curIdx == -1 {
					sorted = append([]string{c.name}, sorted...)
				}
			} else if sortedIdx := getRIndex(sorted, c.before); sortedIdx != -1 {
				if curIdx := getRIndex(sorted, c.name); curIdx == -1 {
					// if before callback already sorted, append current callback just after it

                writer.write(runner.client(), suggester.settings(), suggester.getIndex(), new SuggestItem[] { item }, false);

        assertNotNull(result);
        assertFalse(result.hasFailure());

        runner.refresh();

        GetResponse getResponse =
                runner.client().prepareGet().setIndex(suggester.getIndex()).setId(item.getId()).get(TimeValue.timeValueSeconds(30));

        suggester.createIndexIfNothing();
        Thread.sleep(50);

        // Create additional update index (making 2 total)
        final String updateAlias = suggester.getIndex() + ".update";
        final String extraIndexName = suggester.getIndex() + ".extra";

        client.admin().indices().prepareCreate(extraIndexName).execute().actionGet();

    }

    @Test
    public void test_chatSourceDefaultConstructor() {
        final ChatSource source = new ChatSource();
        assertEquals(0, source.getIndex());
        assertNull(source.getTitle());
        assertNull(source.getUrl());
        assertNull(source.getDocId());
        assertNull(source.getSnippet());
    }

    @Test

        if (logger.isInfoEnabled()) {
            logger.info("Indexing from query logs: count={}, index={}", queryLogs.length, ctx.getIndex());
        }
        try {
            final long start = System.currentTimeMillis();
            Stream<QueryLog> stream = Stream.of(queryLogs);
            if (parallel) {

        this.langFieldName = langFieldName;
        this.badWords = badWords;
    }

    /**
     * Returns the index name.
     * @return The index name.
     */
    public String getIndex() {
        return index;
    }

    /**
     * Returns the supported fields.
     * @return The supported fields.
     */
    public String[] getSupportedFields() {
        return supportedFields;
    }

        final List<SuggestItem> firstItems = new ArrayList<>();
        final List<SuggestItem> secondItems = new ArrayList<>();

        final String index;
        if (hits.length > 0) {
            index = hits[0].getIndex();
        } else {
            index = SuggestConstants.EMPTY_STRING;
        }

        final boolean singleWordQuery = queryBuilder.isSingleWordQuery(query);

 *   <li>{@link #getReadingConverter()}: Returns the ReadingConverter instance.</li>
 *   <li>{@link #getNormalizer()}: Returns the Normalizer instance.</li>
 *   <li>{@link #getIndex()}: Returns the index name.</li>
 *   <li>{@link #getAllWordsNum()}: Returns the total number of words in the suggestion index.</li>

            }
            return value.toString();
        }

        /**
         * Gets the source index.
         *
         * @return the source index
         */
        public int getIndex() {
            return index;
        }

        /**
         * Sets the source index.
         *
         * @param index the source index
         */
        public void setIndex(final int index) {

        public void refresh() {
            // Mock implementation
        }

        public void createIndexIfNothing() {
            // Mock implementation
        }

        public String getIndex() {
            return "fess.suggest";
        }

        public long getAllWordsNum() {
            return 100L;
        }

        public long getDocumentWordsNum() {
            return 50L;