/**
     * Target indices for OpenSearch.
     */
    public static final String TARGET_INDICES = "crawler.opensearch.target_indices";

    /**
     * Logger instance.
     */
    private static final Logger logger = LogManager.getLogger(FesenClient.class);

    /**
     * The OpenSearch client.
     */
    protected Client client;

    /**

 * </ul>
 */
public class ContentOutputStream extends DeferredFileOutputStream {

    /**
     * The logger for this class.
     */
    protected static final Logger logger = Logger.getLogger(ContentOutputStream.class.getName());

    /**
     * The prefix for the temporary file name.
     */
    protected static final String PREFIX = "curl4j-";

    /**

        } catch (final InvalidQueryException e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Invalid query: {}", body.q, e);
            }
            throwValidationErrorApi(e.getMessageCode());
        } catch (final ResultOffsetExceededException e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Invalid offset: {}", body.offset, e);
            }

 * This class is responsible for creating {@link StopwordsFile} instances
 * from files that match the pattern "stopwords.*\\.txt".
 */
public class StopwordsCreator extends DictionaryCreator {
    private static final Logger logger = LogManager.getLogger(StopwordsCreator.class);

    /**
     * Constructs a new creator for stopwords dictionaries.
     * It sets the file pattern to match files starting with "stopwords"
     * and ending with ".txt".

import org.dbflute.util.DfTypeUtil;

/**
 * @author FreeGen
 */
public class SearchLogBhv extends BsSearchLogBhv {
    private static final Logger logger = LogManager.getLogger(SearchLogBhv.class);

    private String indexName = null;

    @Override
    protected String asEsIndex() {
        if (indexName == null) {
            final String name = ComponentUtil.getFessConfig().getIndexLogIndex();

                    if (logger.isDebugEnabled()) {
                        logger.debug("Path {} matches the exclude path expression {} on {} of label.", path, excludedPaths, value);
                    }
                    return false;
                }
                if (logger.isDebugEnabled()) {

                logger.info("Closing index: {}", docIndex);
                searchEngineClient.admin()
                        .indices()
                        .prepareOpen(docIndex)
                        .execute(ActionListener.wrap(res2 -> logger.info("Opened index: {}", docIndex),
                                e -> logger.warn("Failed to open index: {}", docIndex, e)));

        loadProtocols("org.codelibs.fess.net.protocol");

        if (logger.isDebugEnabled()) {
            logger.debug("Web protocols: protocols={}", Arrays.toString(webProtocols));
            logger.debug("File protocols: protocols={}", Arrays.toString(fileProtocols));
        }
    }

    /**

import org.apache.logging.log4j.Logger;
import org.codelibs.core.lang.StringUtil;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.util.ComponentUtil;

/**
 * Factory for creating appropriate StorageClient based on configuration.
 */
public final class StorageClientFactory {

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

        if (httpClient == null) {
            return;
        }
        if (logger.isDebugEnabled()) {
            logger.debug("Closing HTTP client...");
        }
        if (connectionMonitorTask != null) {
            connectionMonitorTask.cancel();
            if (logger.isDebugEnabled()) {
                logger.debug("Connection monitor task cancelled");
            }
        }