assertEquals((byte) 0x74, msg.command, "Command should be SMB_COM_LOGOFF_ANDX");
    }

    @Test
    @DisplayName("constructor with null andx does not throw exception")
    void constructorWithNullAndxNoException() {
        // This test verifies that passing null doesn't cause any issues
        assertDoesNotThrow(() -> {

        return client.admin().indices().prepareRefresh().execute().actionGet(suggestSettings.getIndexTimeout());
    }

    /**
     * Shuts down the thread pool.
     */
    public void shutdown() {
        if (logger.isInfoEnabled()) {
            logger.info("Shutting down suggester: index={}", index);
        }
        threadPool.shutdownNow();
    }

    /**
     * Creates a new index if no index exists.

     * an Atom file, RSS file or a simple text file.
     */
    private String loc;

    /**
     * Identifies the time that the corresponding Sitemap file was modified. It
     * does not correspond to the time that any of the pages listed in that
     * Sitemap were changed. The value for the lastmod tag should be in W3C
     * Datetime format.
     *

            "The system cannot find the file specified.", "Bad password.", "The system cannot find the path specified.", "reserved",
            "The client does not have the necessary access rights to perform the requested function.", "Access is denied.",
            "The TID specified was invalid.", "The handle is invalid.", "The network name cannot be found.",

            "The system cannot find the file specified.", "Bad password.", "The system cannot find the path specified.", "reserved",
            "The client does not have the necessary access rights to perform the requested function.", "Access is denied.",
            "The TID specified was invalid.", "The handle is invalid.", "The network name cannot be found.",

        assertFalse(data.getChildUrlSet().contains(child1));
        assertTrue(data.getChildUrlSet().contains(child2));
    }

    public void test_childUrlSetNoDuplicates() {
        // Test that child URL set does not allow duplicates
        ResponseData data = new ResponseData();

        RequestData child = new RequestData();
        child.setMethod(Method.GET);
        child.setUrl("https://example.com/page1");

     * Shutdown the resource manager
     */
    public void shutdown() {
        if (shutdownInProgress) {
            return;
        }

        shutdownInProgress = true;
        log.info("Shutting down ResourceManager");

        // Cancel cleanup task
        if (cleanupTask != null) {
            cleanupTask.cancel(false);
        }

        // Force cleanup of all resources

        try {
            cleanupScheduler.awaitTermination(5, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            log.warn("Interrupted while shutting down cleanup scheduler", e);
        }

        log.info("Authentication rate limiter closed");
    }

    /**
     * Per-account attempt tracking
     */
    private static class AccountAttempts {

            assertEquals(3, rp.ordinal());
            break;
        default:
            fail("Unexpected name under test: " + name);
        }
    }

    // Edge: valueOf is case-sensitive and does not accept unknown identifiers
    @ParameterizedTest
    @ValueSource(strings = { "none", "No_Retry", "retain_payload", "UNKNOWN", "NO-RETRY" })

            if (Thread.currentThread() == this.thread) {
                // we are in the transport thread, ie. on idle disconnecting
                // this is synchronous operation
                // This does not handle compound requests
                synchronized (this.inLock) {
                    final Long peekKey = peekKey();
                    if (peekKey == firstKey) {
                        doRecv(response);