import java.util.concurrent.atomic.AtomicInteger
import mockwebserver3.junit5.StartStop
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.Timeout

@Timeout(30)
class CustomDispatcherTest {
  @StartStop private val mockWebServer = MockWebServer()

  @Test
  fun simpleDispatch() {
    val requestsMade = mutableListOf<RecordedRequest>()
    val dispatcher: Dispatcher =
      object : Dispatcher() {

 * [okhttp3.OkHttpClient.Builder.authenticator] or [okhttp3.OkHttpClient.Builder.proxyAuthenticator].
 */
class JavaNetAuthenticator(
  private val defaultDns: Dns = Dns.SYSTEM,
) : okhttp3.Authenticator {
  @Throws(IOException::class)
  override fun authenticate(
    route: Route?,
    response: Response,
  ): Request? {

 * This exception is thrown when DCE/RPC protocol errors occur.
 */
public class DcerpcException extends CIFSException implements DcerpcError, WinError {

    /**
     *
     */
    private static final long serialVersionUID = -6113895861333916945L;

    static String getMessageByDcerpcError(final int errcode) {
        int min = 0;
        int max = DCERPC_FAULT_CODES.length;

        while (max >= min) {

 * high-level access to SAM database operations.
 */
public class SamrPolicyHandle extends rpc.policy_handle implements AutoCloseable {

    private final DcerpcHandle handle;
    private boolean opened;

    /**
     * Creates a new SAM policy handle.
     *
     * @param handle the DCE/RPC handle for communication
     * @param server the server name (null defaults to local server)

    protected Set<String> excludedArtifacts;

    private final Set<String> coreArtifacts;

    @Inject
    public DefaultArtifactFilterManager(List<ArtifactFilterManagerDelegate> delegates, CoreExports coreExports) {
        this.delegates = delegates;
        this.coreArtifacts = coreExports.getExportedArtifacts();
    }

    private synchronized Set<String> getExcludedArtifacts() {

import static org.mockito.Mockito.mock;

/**
 */
@Deprecated
class ArtifactDeployerTest extends AbstractArtifactComponentTestCase {
    @Inject
    private ArtifactDeployer artifactDeployer;

    @Inject
    private SessionScope sessionScope;

    protected String component() {
        return "deployer";
    }

    @Test
    void testArtifactInstallation() throws Exception {

 * has exceeded its lifetime and should be refreshed or reloaded.
 */
public class DictionaryExpiredException extends RuntimeException {

    /** Serial version UID for serialization. */
    private static final long serialVersionUID = 1L;

    /**
     * Creates a new instance of DictionaryExpiredException.
     * This constructor initializes the exception to indicate that a dictionary

 * Typically used when a document or resource is not available during crawling or indexing.
 */
public class ContentNotFoundException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    /**
     * Constructs a new ContentNotFoundException with the specified parent URL and URL.
     *
     * @param parentUrl the URL of the parent document

 * attempting to read beyond the end of a file.
 *
 * @author mbechler
 */
public class SmbEndOfFileException extends SmbException {

    /**
     *
     */
    private static final long serialVersionUID = 298752101881244000L;

    /**
     * Constructs an end-of-file exception.
     */
    public SmbEndOfFileException() {
        super("Unexpectedly reached end of file");
    }

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

/**
 * Base class for all maven exceptions.
 *
 * @since 4.0.0
 */
@Experimental
public class MavenException extends RuntimeException {

    @Serial
    private static final long serialVersionUID = 9027638326336093132L;

    public MavenException() {}

    public MavenException(String message) {
        super(message);
    }