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());

- CLI client. This is the `gradle` or `gradlew` command, and is responsible for locating, starting and interacting with the Gradle daemon, potentially downloading the Gradle distribution. 
- Tooling API client. This a library that is embedded into applications, such as IDEs or CI agents, that allows them to act as a Gradle client.

import org.codelibs.fess.app.service.WebConfigService;
import org.codelibs.fess.crawler.client.http.config.CredentialsConfig;
import org.codelibs.fess.crawler.client.http.config.CredentialsConfig.CredentialsType;
import org.codelibs.fess.crawler.client.http.config.WebAuthenticationConfig;
import org.codelibs.fess.crawler.client.http.config.WebAuthenticationConfig.AuthSchemeType;
import org.codelibs.fess.crawler.exception.CrawlerSystemException;

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;

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;

            // If it succeeds, check that lastUpdated is set
            assertNotNull(jobLog.getLastUpdated());
        } catch (Exception e) {
            // Expected in test environment due to missing client
            assertTrue(e.getMessage().contains("client"));
        }
    }

    @Test
    public void test_monitorTarget_expired_withEndTime() {
        JobLog jobLog = new JobLog();
        jobLog.setId("test-log-2");

        return ComponentUtil.getFessConfig().getIndexLogIndex() + ".notification_queue";
    }

    private void ensureIndexExists(final SearchEngineClient client, final String indexName) {
        if (!indexChecked) {
            if (!client.existsIndex(indexName)) {
                client.createIndex(NOTIFICATION_QUEUE_INDEX, indexName);
            }
            indexChecked = true;
        }
    }

Below is the protocol in some more detail:

1. The client looks for a compatible idle daemon. If there isn't one, it starts a new daemon.
2. The client connects to the idle daemon and sends it a request to do some work. If the daemon is no longer running, the client starts again.
3. If the daemon is not able to run the request, for example it is already running a request or is shutting down, it rejects the request. The client starts again.

        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) {