* Constructs a new TransportException with the specified cause.
     * @param rootCause the cause of this exception
     */
    public TransportException(final Throwable rootCause) {
        super(rootCause);
    }

    /**
     * Constructs a new TransportException with the specified detail message and cause.
     * @param msg the detail message
     * @param rootCause the cause of this exception
     */

import org.junit.jupiter.api.Test;

import static org.junit.jupiter.api.Assertions.assertThrows;

@Deprecated
public class GraphTest {

    @Test
    void testCycle() throws Graph.CycleDetectedException {
        Graph graph = new Graph();
        graph.addEdge("a1", "a2");
        assertThrows(Graph.CycleDetectedException.class, () -> graph.addEdge("a2", "a1"));
    }

    @Test
    public void testPerf() throws IOException {

import java.util.stream.Collectors;
import java.util.stream.IntStream;

/**
 * The methods in this class take a shell command and wrap it in retry logic, so that our
 * Docker builds can be more robust in the face of transient errors e.g. network issues.
 */
public class ShellRetry {
    static String loop(String name, String command) {
        return loop(name, command, 4, "exit");
    }

   * returns {@code true} if {@code a == b}, including in the case that a and b are both null.
   *
   * @since 13.0
   * @since 4.0 (in Equivalences)
   */
  public static Equivalence<Object> identity() {
    return Identity.INSTANCE;
  }

  static final class Equals extends Equivalence<Object> implements Serializable {

    static final Equals INSTANCE = new Equals();

 */
public class ApiAdminDictStemmeroverrideAction extends FessApiAdminAction {

    /**
     * Default constructor.
     */
    public ApiAdminDictStemmeroverrideAction() {
        super();
    }

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

    @Resource

import jakarta.servlet.http.HttpServletRequest;

/**
 * Helper class for rate limiting functionality.
 * Implements a sliding window algorithm for request counting
 * and manages IP-based blocking using Guava Cache for automatic expiration.
 */
public class RateLimitHelper {

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

    /**
     * Request counters per IP address.

        Object setResult = data.getDataMap().get("set");
        assertNotNull(setResult);
        assertTrue(setResult instanceof List);
    }

    // Test helper class
    public static class ComplexObject {
        private String value;

        public String getValue() {
            return value;
        }

        public void setValue(String value) {

is resilient and can automatically recover from some connectivity failures. In this case, the `connectFailed()` event is not terminal and not followed by `callFailed()`. Event listeners will receive multiple events of the same type when retries are attempted.

A single HTTP call may require follow-up requests to be made to handle authentication challenges, redirects, and HTTP-layer timeouts. In such cases multiple connections, requests, and responses may be attempted. Follow-ups are another...

@SuppressWarnings("JUnit4ClassUsedInJUnit3")
public class CollectionRetainAllTester<E> extends AbstractCollectionTester<E> {

  /** A collection of elements to retain, along with a description for use in failure messages. */
  private final class Target {
    private final Collection<E> toRetain;
    private final String description;

 * behavior of {@link #addAll}, which can lead to unexpected behavior. In this case, you should
 * override {@code addAll} as well, either providing your own implementation, or delegating to the
 * provided {@code standardAddAll} method.
 *
 * <p><b>{@code default} method warning:</b> This class does <i>not</i> forward calls to {@code