import org.apache.logging.log4j.Logger;
import org.apache.lucene.search.TotalHits;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.opensearch.client.SearchEngineClient;
import org.codelibs.fess.opensearch.client.SearchEngineClientException;
import org.codelibs.fess.thumbnail.ThumbnailManager;
import org.codelibs.fess.util.ComponentUtil;
import org.codelibs.fess.util.DocList;

        }
        final LlmClient client = getClient();
        if (client == null || !client.isAvailable()) {
            throw new LlmException("LLM client is not available");
        }
        return client;
    }

    // RAG workflow delegation methods

    /**
     * Detects the intent of a user message using the configured LLM client.
     *

import org.codelibs.core.timer.TimeoutManager;
import org.codelibs.core.timer.TimeoutTask;
import org.codelibs.fess.Constants;
import org.codelibs.fess.crawler.client.FesenClient;
import org.codelibs.fess.exception.ContainerNotAvailableException;
import org.codelibs.fess.opensearch.client.SearchEngineClient;
import org.codelibs.fess.timer.LogNotificationTarget;
import org.codelibs.fess.timer.SystemMonitorTarget;

import org.opensearch.transport.client.Client;

import jakarta.annotation.Resource;

/**
 * @param <ENTITY> The type of entity.
 * @param <CB> The type of condition-bean.
 * @author ESFlute (using FreeGen)
 */
public abstract class EsAbstractBehavior<ENTITY extends Entity, CB extends ConditionBean> extends AbstractBehaviorWritable<ENTITY, CB> {

    @Resource
    private Client client;

                return Collections.emptyList();
            }
        };
        ComponentUtil.register(client, "searchEngineClient");
        final DocList docList = new DocList();
        indexingHelper.sendDocuments(client, docList);
        assertEquals(0, docList.size());
        assertEquals(0, sentDocList.size());
        assertNull(sentIndex.get());

                    logger.warn("Failed to send error response. error={}", ioe.getMessage());
                }
            }
        }
    }

    /**
     * Sends a Server-Sent Event (SSE) to the client.
     *
     * @param writer the print writer to write the event to
     * @param event the event name
     * @param data the event data to serialize as JSON
     */

1. **Import your GSA configuration** using the method described above
2. **Update client applications** to use Fess's JSON Search API (see [API Reference](#api-reference) section)
3. **Gradually migrate** from GSA query format to Fess's native API

import org.opensearch.transport.client.Client;

import jakarta.annotation.Resource;

/**
 * @param <ENTITY> The type of entity.
 * @param <CB> The type of condition-bean.
 * @author ESFlute (using FreeGen)
 */
public abstract class EsAbstractBehavior<ENTITY extends Entity, CB extends ConditionBean> extends AbstractBehaviorWritable<ENTITY, CB> {

    @Resource
    private Client client;

    /**
     * Retrieves the appropriate crawler client for the given URL based on configured rules.
     * This method uses client rules to determine which specific client implementation
     * should be used for crawling the URL, falling back to the default client if no
     * specific rule matches.
     *
     * @param url the URL to get a client for
     * @return the crawler client instance to use for the URL
     */
    @Override

        final List<Map<String, Object>> fileList = new ArrayList<>();

        try (final StorageClient client = StorageClientFactory.createClient(fessConfig)) {
            // Ensure bucket exists on first access
            client.ensureBucketExists();

            final List<StorageItem> items = client.listObjects(prefix, fessConfig.getStorageMaxItemsInPageAsInteger());

            for (final StorageItem item : items) {