}

    public void test_setEcsServiceName() {
        activityHelper.setEcsServiceName("test-service");
        activityHelper.useEcsFormat = true;
        activityHelper.login(OptionalThing.empty());
        assertTrue(localLogMsg.get().contains("\"service.name\":\"test-service\""));
    }

    public void test_setEcsEventDataset() {
        activityHelper.setEcsEventDataset("test-dataset");

	</component>

	<!-- Service -->
	<component name="urlQueueService" class="org.codelibs.fess.crawler.service.impl.UrlQueueServiceImpl" instance="prototype" >
	</component>
	<component name="dataService" class="org.codelibs.fess.crawler.service.impl.DataServiceImpl" instance="prototype" >
	</component>
	<component name="urlFilterService" class="org.codelibs.fess.crawler.service.impl.UrlFilterServiceImpl" instance="prototype" >

**We recommend setting `policy` as a custom claim for the JWT service provider follow [here](https://docs.wso2.com/display/IS550/Configuring+Claims+for+a+Service+Provider) and [here](https://docs.wso2.com/display/IS550/Handling+Custom+Claims+with+the+JWT+Bearer+Grant+Type) for relevant docs on how to configure claims for a service provider.**

### 5. Setup MinIO with OpenID configuration URL

    } finally {
      service.shutdown();
    }
  }

  public void testEnqueueAndDispatch_multithreaded_withThrowingRunnable()
      throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);
    ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
    try {
      queue.addListener(listener, service);

    } finally {
      service.shutdown();
    }
  }

  public void testEnqueueAndDispatch_multithreaded_withThrowingRunnable()
      throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);
    ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
    try {
      queue.addListener(listener, service);

echo "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY" | docker secret create secret_key -
```

Create a MinIO service using `docker service` to read from Docker secrets.

```
docker service create --name="minio-service" --secret="access_key" --secret="secret_key" quay.io/minio/minio server /data
```

Read more about `docker service` [here](https://docs.docker.com/engine/swarm/how-swarm-mode-works/services/)

import java.util.Collection;
import java.util.Objects;

import org.apache.maven.api.Service;
import org.apache.maven.api.annotations.Experimental;
import org.apache.maven.api.annotations.Nonnull;

/**
 * Service for creating {@link PathMatcher} objects that can be used to filter files
 * based on include/exclude patterns. This service provides a clean API for plugins

    /**
     * Gets or creates an SMB tree connection for the specified share and service.
     *
     * @param share the share name to connect to
     * @param service the service type for the connection
     * @return tree instance
     */
    SmbTree getSmbTree(String share, String service);

    /**
     * Initiate reauthentication
     *
     * @throws CIFSException if reauthentication fails

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.service;

import java.util.List;
import java.util.Map;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.fess.crawler.entity.OpenSearchUrlQueue;
import org.codelibs.fess.crawler.service.impl.OpenSearchUrlQueueService;
import org.codelibs.fess.crawler.util.OpenSearchCrawlerConfig;

        super(config, andx);
    }

    /**
     * @return the service
     */
    @Override
    public final String getService() {
        return this.service;
    }

    /**
     * Returns the native file system type of the connected share.
     *
     * @return the nativeFileSystem
     */
    public final String getNativeFileSystem() {
        return this.nativeFileSystem;
    }

    /**