*/
    protected int activeMaxPort;

    /**
     * Whether to autodetect encoding.
     */
    protected boolean autodetectEncoding;

    /**
     * The connect timeout.
     */
    protected int connectTimeout;

    /**
     * The data timeout.
     */
    protected int dataTimeout;

    /**
     * The control encoding.
     */
    protected String controlEncoding;

     */
    protected String charset = Constants.UTF_8;

    /**
     * Helper for managing content length validation and limits.
     */
    @Resource
    protected ContentLengthHelper contentLengthHelper;

    /**
     * Flag indicating whether the client has been initialized.
     */
    protected volatile boolean isInit = false;

    /**

    /** Index name. */
    protected final String indexName;
    /** Supported fields. */
    protected final String[] supportedFields;

    /** Scroll size. */
    protected int scrollSize = 1;
    /** Maximum retry count. */
    protected int maxRetryCount = 5;
    /** Limit of document size. */
    protected long limitOfDocumentSize = 50000;
    /** Query builder. */

     *
     * @param objs the log objects
     */
    protected void processDefault(final Object... objs) {
    }

    /**
     * Processes system error log events.
     *
     * @param objs the log objects (should contain a Throwable)
     */
    protected void processSystemError(final Object... objs) {
        final Throwable t = (Throwable) objs[0];

/**
 * Extracts text content from an input stream as plain text.
 */
public class TextExtractor extends AbstractExtractor {

    /**
     * The encoding for text.
     */
    protected String encoding = Constants.UTF_8;

    /**
     * Creates a new TextExtractor instance.
     */
    public TextExtractor() {
        super();
    }

    @Override

public class SuggestIndexResponse implements Response {
    /** The number of suggest documents. */
    protected final int numberOfSuggestDocs;
    /** The number of input documents. */
    protected final int numberOfInputDocs;
    /** Flag indicating if there are errors. */
    protected final boolean hasError;
    /** List of errors. */
    protected final List<Throwable> errors = new ArrayList<>();
    /** Time taken for the operation in milliseconds. */

     * The index associated with the response.
     */
    protected final String index;

    /**
     * The time taken to generate the response in milliseconds.
     */
    protected final long tookMs;

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

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

    /**

     */
    @Resource
    protected CrawlerContainer crawlerContainer;

    /**
     * The URL pattern.
     */
    protected String urlPattern = "^(.*:/+)([^/]*)(.*)$";

    /**
     * The include filtering pattern.
     */
    protected String includeFilteringPattern;

    /**
     * The exclude filtering pattern.
     */
    protected String excludeFilteringPattern;

    /**

 * @author shinsuke
 *
 */
public class SmbClientTest extends PlainTestCase {

    public void test_doGet_accessTimeoutTarget() {
        SmbClient client = new SmbClient() {
            @Override
            protected ResponseData getResponseData(final String uri, final boolean includeContent) {
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {

    protected long maxUncompressionSize = 1000000;

    /**
     * Initial buffer size.
     */
    protected int initialBufferSize = 10000;

    /**
     * If true, duplicated terms are replaced.
     */
    protected boolean replaceDuplication = false;

    /**
     * Space characters. Default includes common space characters.
     */
    protected int[] spaceChars = { '\u0020', '\u00a0', '\u3000', '\ufffd' };