}

    /**
     * Gets the crawler client factory component.
     * @return The crawler client factory.
     */
    public static CrawlerClientFactory getCrawlerClientFactory() {
        return getComponent(CrawlerClientFactory.class);
    }

    /**
     * Gets the crawler client creator component.
     * @return The crawler client creator.
     */

            } catch (final ClientAbortException e) {
                logger.debug("Client aborts this request.", e);
            }
        } catch (final Exception e) {
            if (!(e.getCause() instanceof ClientAbortException)) {
                throw new WebApiException(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, e);
            }
            logger.debug("Client aborts this request.", e);
        }
    }

    /**

        final CrawlerClient client = crawlerClientFactory.getClient(url);
        if (client == null) {
            throw new FessSystemException("No CrawlerClient: " + configId + ", url: " + url);
        }
        return writeContent(configId, url, client);
    }

    /**
     * Writes content from a crawler client to a stream response.
     *
     * @param configId the configuration ID

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE components PUBLIC "-//DBFLUTE//DTD LastaDi 1.0//EN" 
	"http://dbflute.org/meta/lastadi10.dtd">
<components>
	<component name="fesenClient"
		class="org.codelibs.fess.opensearch.client.CrawlerEngineClient">
	</component>

        final CrawlerClient client = crawlerClientFactory.getClient(url);
        if (client == null) {
            throw new CrawlingAccessException(
                    "CrawlerClient is null for URL: " + url + ". Unable to access the document without a crawler client.");
        }

        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.opensearch.client;

import org.codelibs.fess.exception.FessSystemException;

/**
 * Exception thrown when search engine client operations fail.
 * This exception wraps underlying search engine errors and provides
 * meaningful error messages for troubleshooting.
 */

#         ; freeGenList = list:{ [env or config or label or message or html] }
#         ; propertiesHtmlList = list:{ [env or config or label or message] }
#     }
#     ; appMap = map:{
#         ; [application name, camel case, initial uncapitalised] = map:{
#             ; path = [relative path to application project from DBFlute client]

        this.systemHelper = systemHelper;
    }

    @Override
    public void expired() {
        try {
            final SearchEngineClient client = ComponentUtil.getSearchEngineClient();
            final NodesStatsResponse response = client.admin().cluster().prepareNodesStats().addMetric("os").execute().actionGet(10000L);

            short maxCpu = 0;
            for (final NodeStats nodeStats : response.getNodes()) {

        if (opLambda != null) {
            opLambda.callback(builder);
        }
    }

    public void setClientIp_SpanTerm(String clientIp) {
        setClientIp_SpanTerm("clientIp", null);
    }

    public void setClientIp_SpanTerm(String clientIp, ConditionOptionCall<SpanTermQueryBuilder> opLambda) {
        SpanTermQueryBuilder builder = regSpanTermQ("clientIp", clientIp);

import org.apache.logging.log4j.Logger;
import org.codelibs.core.lang.StringUtil;
import org.codelibs.curl.Curl.Method;
import org.codelibs.curl.CurlRequest;
import org.codelibs.fesen.client.curl.FesenRequest;
import org.codelibs.fesen.client.node.NodeManager;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.util.ComponentUtil;
import org.codelibs.fess.util.ResourceUtil;