or as an addendum to the NOTICE text from the Work, provided
          that such additional attribution notices cannot be construed
          as modifying the License.

      You may add Your own copyright statement to Your modifications and
      may provide additional or different license terms and conditions
      for use, reproduction, or distribution of Your modifications, or

          or as an addendum to the NOTICE text from the Work, provided
          that such additional attribution notices cannot be construed
          as modifying the License.

      You may add Your own copyright statement to Your modifications and
      may provide additional or different license terms and conditions
      for use, reproduction, or distribution of Your modifications, or

        assertFalse(urlFilter.match("javascript:alert('test')"));
        assertFalse(urlFilter.match("mailto:******@****.***"));
    }

    /**
     * Test concurrent pattern additions
     */
    public void test_concurrentPatternAdditions() throws InterruptedException {
        String sessionId = "test-session-023";
        urlFilter.init(sessionId);

        return "<field name=\"" + XmlUtil.escapeXml(name) + "\">" + buf.toString().trim() + "</field>\n";
    }

    /**
     * Returns the additional data for the response.
     * @param responseData The response data.
     * @param document The document.
     * @return The additional data.
     */
    protected String getAdditionalData(final ResponseData responseData, final Document document) {
        return "";
    }

            }
        }
    }

    /**
     * Extracts text from the input stream using the API endpoint.
     *
     * @param in the input stream to extract text from
     * @param params additional parameters
     * @return the extracted data
     * @throws ExtractException if extraction fails
     */
    @Override
    public ExtractData getText(final InputStream in, final Map<String, String> params) {

        return "<field name=\"" + XmlUtil.escapeXml(name) + "\">" + buf.toString().trim() + "</field>\n";
    }

    /**
     * Returns additional data for the result.
     * @param responseData The response data.
     * @param document The XML document.
     * @return Additional data as a string.
     */
    protected String getAdditionalData(final ResponseData responseData, final Document document) {
        return "";
    }

            throw new IORuntimeException(e);
        }
    }

    /**
     * Parses request parameters from a string.
     * @param params The parameter string.
     * @param paramList Additional parameters.
     * @param encoding The encoding.
     * @return The HttpEntity containing the parsed parameters.
     */

 */
package org.codelibs.opensearch.extension.analysis;

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with

        assertEquals(2, ruleManager.getGetRuleCallCount());

        ruleManager.getRule(null);
        assertEquals(3, ruleManager.getGetRuleCallCount());
    }

    /**
     * Test concurrent rule additions
     */
    public void test_concurrentAddRule() throws Exception {
        final ThreadSafeRuleManager threadSafeManager = new ThreadSafeRuleManager();
        final int threadCount = 10;