}

        int maxUaLength = -1;
        Directive matchedDirective = null;
        for (final Map.Entry<Pattern, Directive> entry : directiveMap.entrySet()) {
            if (entry.getKey().matcher(target).find()) {
                final Directive directive = entry.getValue();
                final String ua = directive.getUserAgent();
                int uaLength = 0;

        final List<AnalyzeToken> tokens = analyzer.analyze(text, "", null);
        final List<AnalyzeToken> readingTokens = analyzer.analyzeAndReading(text, "", null);

        int matchCount = 0;
        for (int i = 0; i < tokens.size(); i++) {
            final String term = tokens.get(i).getTerm();
            final String reading = readingTokens.get(i).getTerm();
            switch (term) {
            case "fess":

 * </p>
 */
public class AccessTimeoutTarget implements TimeoutTarget {

    private static final Logger logger = LogManager.getLogger(AccessTimeoutTarget.class);

    private static final int MAX_LOOP_COUNT = 10;

    /** The thread being monitored. */
    protected Thread runningThread;

    /** Flag indicating if the thread is still running. */
    protected AtomicBoolean running = new AtomicBoolean();

            @Override
            public ExtractData getText(InputStream in, Map<String, String> params) {
                return null;
            }

            @Override
            public int getWeight() {
                return 10;
            }
        });
        assertEquals(10, extractorFactory.getExtractor(key).getWeight());
        assertEquals(1, extractorFactory.getExtractors(key)[1].getWeight());

            }
            stream.reset();

            int offset = 0;
            while (stream.incrementToken()) {
                final CharTermAttribute att = stream.getAttribute(CharTermAttribute.class);
                final String term = att.toString();
                final int pos = inputStr.indexOf(term, offset);
                if (pos > 0) {

        final InputStream in = ResourceUtil.getResourceAsStream("extractor/tar/test.tar");
        final String content = tarExtractor.getText(in, null).getContent();
        CloseableUtil.closeQuietly(in);
        logger.info(content);
        assertTrue(content.contains("テスト"));
        assertTrue(content.contains("テキスト"));
    }

    public void test_getText_maxSize() throws IOException {

    /**
     * Test thread safety of enum
     */
    public void test_threadSafety() throws Exception {
        final int threadCount = 100;
        final int iterationsPerThread = 1000;
        final Set<Exception> exceptions = new HashSet<>();

        Thread[] threads = new Thread[threadCount];
        for (int i = 0; i < threadCount; i++) {
            threads[i] = new Thread(new Runnable() {
                @Override

                final String settingsSource = getDefaultIndexSettings();
                final String indexName = createIndexName(index);
                if (logger.isInfoEnabled()) {
                    logger.info("Create suggest index: {}", indexName);
                }

                client.admin()
                        .indices()
                        .prepareCreate(indexName)

    /** The time taken in milliseconds. */
    protected final long tookMs;

    /** The list of suggested words. */
    protected final List<String> words;

    /** The number of suggested words. */
    protected final int num;

    /** The total number of hits. */
    protected final long total;

    /** The list of suggested items. */
    protected final List<SuggestItem> items;

    /**
     * Constructor for SuggestResponse.

            final StringBuilder readingBuf = new StringBuilder(text.length());
            if (readingTokenList != null && termTokenList != null) {
                int offset = 0;
                for (int i = 0; i < readingTokenList.size(); i++) {
                    final String term = termTokenList.get(i).getTerm();
                    String reading = readingTokenList.get(i).getTerm();