assertTrue(messages.hasMessageOf(property));
    }

    public void test_addConstraintsPastMessage() {
        String property = "testProperty";
        FessMessages result = messages.addConstraintsPastMessage(property);
        assertNotNull(result);
        assertSame(messages, result);
        assertTrue(messages.hasMessageOf(property));
    }

                messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY);
        final VaMessenger<FessMessages> parseErrorCode =
                messages -> messages.addErrorsInvalidQueryParseError(UserMessages.GLOBAL_PROPERTY_KEY);

        // Execute
        final InvalidQueryException unknownException = new InvalidQueryException(unknownErrorCode, message);

    public void test_differentMessageCodes() {
        // Setup - test with different message codes
        final String message = "Test message";
        final VaMessenger<FessMessages> loginErrorCode = messages -> messages.addErrorsSsoLoginError(UserMessages.GLOBAL_PROPERTY_KEY);
        final VaMessenger<FessMessages> logoutErrorCode = messages -> messages.addSuccessSsoLogout(UserMessages.GLOBAL_PROPERTY_KEY);

        // Execute

        // Number of messages
        int numberOfMessages = buf.dec_ndr_long();

        // Messages array
        List<WitnessNotificationMessage> messages = new ArrayList<>(numberOfMessages);
        for (int i = 0; i < numberOfMessages; i++) {
            WitnessNotificationMessage message = decodeNotificationMessage(buf);
            messages.add(message);
        }

**FastAPI** provides the same `WebSocket` directly just as a convenience for you, the developer. But it comes directly from Starlette.

///

## Await for messages and send messages { #await-for-messages-and-send-messages }

In your WebSocket route you can `await` for messages and send messages.

{* ../../docs_src/websockets/tutorial001.py hl[48:52] *}

You can receive and send binary, text, and JSON data.

## Try it { #try-it }

        assertEquals(message, exception.getMessage());
        assertNull(exception.getCause());
    }

    public void test_constructor_withMessageAndNullCause() {
        // Test constructor with message and null cause
        String message = "LDAP error occurred";
        LdapOperationException exception = new LdapOperationException(message, null);

        assertEquals(message, exception.getMessage());

        assertEquals("Should have one type parameter", 1, typeParameters.length);
        assertEquals("Type parameter should be MESSAGES", "MESSAGES", typeParameters[0].getName());
    }

    public void test_packageStructure() {
        final Package pkg = FessActionValidator.class.getPackage();
        assertNotNull("Package should not be null", pkg);

    /**
     * Gets the size of the original unencrypted message
     *
     * @return the original message size
     */
    public int getOriginalMessageSize() {
        return this.originalMessageSize;
    }

    /**
     * Sets the size of the original unencrypted message
     *
     * @param originalMessageSize
     *            the original message size to set
     */

import jcifs.internal.CommonServerMessageBlockResponse;
import jcifs.internal.Request;

/**
 * Base class for SMB2/SMB3 request messages.
 *
 * This abstract class provides common functionality for handling
 * request messages in the SMB2/SMB3 protocol.
 *
 * @author mbechler
 * @param <T>
 *            response type
 */

	"github.com/minio/minio/internal/logger/target/console"
	types "github.com/minio/minio/internal/logger/target/loggertypes"
	"github.com/minio/minio/internal/pubsub"
	xnet "github.com/minio/pkg/v3/net"
)

// number of log messages to buffer
const defaultLogBufferCount = 10000

// HTTPConsoleLoggerSys holds global console logger state
type HTTPConsoleLoggerSys struct {
	totalMessages  int64
	failedMessages int64

	sync.RWMutex