import org.codelibs.fess.util.ComponentUtil;

/**
 * Interface for transforming and processing crawled documents in Fess.
 * Provides utility methods for URL processing, site extraction, data mapping,
 * and field configuration handling during the document transformation process.
 */
public interface FessTransformer {

    /**
     * Synchronized LRU cache for storing parent URL encodings.

import org.codelibs.opensearch.runner.OpenSearchRunner;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;

/**
 * Tests for error handling scenarios in SuggestIndexer.
 */
public class SuggestIndexerErrorHandlingTest {
    private static final String TEST_ID = "SuggestIndexerErrorHandlingTest";

    private static final long ASYNC_TIMEOUT_SECONDS = 5L;

import org.codelibs.fess.util.ComponentUtil;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;

/**
 * Test class for FessTransformer interface.
 * Tests the array handling improvements and data merging functionality.
 */
public class FessTransformerTest extends UnitFessTestCase {

    // Test implementation of FessTransformer for testing

   *
   * <p><b>Note:</b> the values of the metrics are undefined in case of overflow (though it is
   * guaranteed not to throw an exception). If you require specific handling, we recommend
   * implementing your own stats collector.
   */
  public long requestCount() {
    return saturatedAdd(hitCount, missCount);
  }

   *
   * <p><b>Note:</b> the values of the metrics are undefined in case of overflow (though it is
   * guaranteed not to throw an exception). If you require specific handling, we recommend
   * implementing your own stats collector.
   */
  public long requestCount() {
    return saturatedAdd(hitCount, missCount);
  }

        assertNotNull(result);
        assertTrue(result instanceof TestUser);
        assertEquals("TestUser", ((TestUser) result).name);
    }

    // Test evaluate method with error handling
    @Test
    public void test_evaluate_withErrorTemplate() {
        scriptEngine = new ErrorHandlingScriptEngine();
        String template = "error";
        Map<String, Object> paramMap = new HashMap<>();

    private static SamrPolicyHandle createMockPolicyHandle() {
        return mock(SamrPolicyHandle.class);
    }

    @Nested
    @DisplayName("Constructor parameter handling")
    class ConstructorParameterHandling {

        static Stream<Arguments> provideParameters() {

///

With that you can connect the WebSocket and then send and receive messages:

<img src="/img/tutorial/websockets/image05.png">

## Handling disconnections and multiple clients { #handling-disconnections-and-multiple-clients }

///

## 사용 사례 { #use-cases }

사용 사례에는 다음이 포함됩니다:

* JSON이 아닌 요청 바디를 JSON으로 변환하기(예: [`msgpack`](https://msgpack.org/index.html)).
* gzip으로 압축된 요청 바디 압축 해제하기.
* 모든 요청 바디를 자동으로 로깅하기.

## 커스텀 요청 바디 인코딩 처리하기 { #handling-custom-request-body-encodings }

커스텀 `Request` 서브클래스를 사용해 gzip 요청의 압축을 해제하는 방법을 살펴보겠습니다.

그리고 그 커스텀 요청 클래스를 사용하기 위한 `APIRoute` 서브클래스도 함께 보겠습니다.

### 커스텀 `GzipRequest` 클래스 만들기 { #create-a-custom-gziprequest-class }

import java.io.IOException;
import java.net.SocketException;
import java.net.SocketTimeoutException;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * RDMA error handling and recovery logic.
 *
 * This class provides centralized error handling for RDMA operations,
 * including retry logic and fallback mechanisms.
 */
public class RdmaErrorHandler {