private void runServer() {
        while (running.get() && !serverSocket.isClosed()) {
            try {
                Socket clientSocket = serverSocket.accept();
                // In a real implementation, this would handle RPC requests
                // For the mock, we just accept connections and close them
                clientSocket.close();
            } catch (IOException e) {
                if (running.get()) {

    /**
     * Flag representing parser processing result: if there were some fatal errors during
     * {@link Parser#parseInvocation(ParserRequest)} this method will return {@code true} and invoker should
     * handle this request as "early failure". In these cases, {@link #options()} usually is absent.
     */
    boolean parsingFailed();

    /**
     * Returns {@code true} if this call happens in "embedded" mode.
     *

 * retry counts and intervals between attempts.
 *
 * <p>The client supports a RequestListener interface to monitor the request lifecycle and handle
 * exceptions during retries.</p>
 *
 * <p>Key features:</p>
 * <ul>
 *   <li>Configurable maximum retry attempts</li>
 *   <li>Adjustable interval between retries</li>
 *   <li>Exception tracking and aggregation</li>

        }
        return super.hookBefore(runtime);
    }

    /**
     * Returns the login manager for this action. Search actions do not require
     * a login manager as they handle authentication differently.
     *
     * @return an empty OptionalThing as search actions don't use login managers
     */
    @Override
    protected OptionalThing<LoginManager> myLoginManager() {

import static java.util.Objects.requireNonNull;

import java.util.ArrayDeque;
import java.util.Iterator;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * Handler for dispatching events to subscribers, providing different event ordering guarantees that
 * make sense for different situations.
 *
 * <p><b>Note:</b> The dispatcher is orthogonal to the subscriber's {@code Executor}. The dispatcher

// I want to set up a local/remote repositories for testing but I don't want to have
// to change them when I change the layout of the repositories. So I want to generate
// the structure I want to test by using the artifact handler manager which dictates
// the layout used for a particular artifact type.

/**
 */
@Deprecated
class ArtifactResolverTest extends AbstractArtifactComponentTestCase {
    @Inject

        assertEquals("test_session_123", options.sessionId);
    }

    @Test
    public void test_process_withPropertiesPath() throws Exception {
        // Test that properties path is properly handled
        // Create temporary properties file
        File propFile = File.createTempFile("test", ".properties");
        propFile.deleteOnExit();

import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpSession;

/**
 * Helper class for managing user information and session tracking in Fess search system.
 * This class handles user identification through cookies, session management, and query tracking.
 * It provides functionality for generating unique user codes, managing user sessions,

///

/// tip | Tipp

Anstatt eine `StreamingResponse` direkt zurückzugeben, sollten Sie wahrscheinlich dem Stil in [Daten streamen](./stream-data.md) folgen. Das ist wesentlich bequemer und behandelt den Abbruch im Hintergrund für Sie.

Wenn Sie JSON Lines streamen, folgen Sie dem Tutorial [JSON Lines streamen](../tutorial/stream-json-lines.md).

///

### `FileResponse` { #fileresponse }

        void shouldCompareVersionsCorrectly() {
            // Based on the actual implementation, it only handles specific cases
            assertTrue(ModelVersionUtils.isVersionGreaterOrEqual("4.1.0", "4.1.0"));
            assertFalse(ModelVersionUtils.isVersionGreaterOrEqual("4.0.0", "4.1.0"));
            // The implementation doesn't handle 4.1.0 >= 4.0.0 comparison
            assertFalse(ModelVersionUtils.isVersionGreaterOrEqual("4.1.0", "4.0.0"));