// Create and populate the RPC message
            WitnessHeartbeatMessage message = new WitnessHeartbeatMessage();
            message.setContextHandle(request.getContextHandle());
            message.setSequenceNumber(request.getSequenceNumber());

            // Send the RPC request
            rpcHandle.sendrecv(message);

            // Create response from RPC message results

    private static final long serialVersionUID = 1L;

    /**
     * Constructor.
     * @param message The exception message.
     */
    public ResultOffsetExceededException(final String message) {
        super(message);
    }

    public ClIndexOutOfBoundsException() {
        super();
    }

    /**
     * Creates a {@link ClIndexOutOfBoundsException}.
     *
     * @param message
     *            Message
     */
    public ClIndexOutOfBoundsException(final String message) {
        super(message);
    }

        logger.error(message, t);
    }

    @Override
    public boolean isWarnEnabled() {
        return logger.isWarnEnabled();
    }

    @Override
    public void warn(final String message) {
        logger.warn(message);
    }

    @Override
    public void warn(final String message, final Throwable t) {
        logger.warn(message, t);
    }

    @DisplayName("Message-only constructor: preserves provided message; null cause")
    void messageOnlyConstructor_preservesMessage(String message) {
        // Arrange & Act
        SMBProtocolDecodingException ex = new SMBProtocolDecodingException(message);

        // Assert message and cause
        assertEquals(message, ex.getMessage(), "Message should be preserved as provided");

    protected final String argName;

    /** Message code */
    protected final String messageCode;

    /** Arguments for the message */
    protected final Object[] args;

    /**
     * Creates a {@link ClIllegalArgumentException}.
     *
     * @param argName
     *            Name of the argument
     * @param messageCode
     *            Message code
     * @param args
     *            Array of arguments

        };
    }

    /**
     * Creates a Type 3 (authentication) message in response to a Type 2 (challenge) message.
     * @param token the Type 2 message bytes
     * @return the Type 3 message bytes
     * @throws SmbException if an error occurs during message creation
     */
    protected byte[] makeAuthenticate(final byte[] token) throws SmbException {
        try {

    /**
    * Specifies that communication across the authenticated channel
    * should carry a digital signature (message integrity).
    */
    int NTLMSSP_NEGOTIATE_SIGN = 0x00000010;

    /**
    * Specifies that communication across the authenticated channel
    * should be encrypted (message confidentiality).
    */
    int NTLMSSP_NEGOTIATE_SEAL = 0x00000020;

    /**
    * Indicates datagram authentication.

        logger.logp(Level.WARNING, sourceClass, null, message);
    }

    @Override
    public void warn(final String message, final Throwable t) {
        logger.logp(Level.WARNING, sourceClass, null, message, t);
    }

    @Override
    public boolean isInfoEnabled() {
        return logger.isLoggable(Level.INFO);
    }

    @Override
    public void info(final String message) {

import org.junit.jupiter.api.Test

class StatusLineTest {
  @Test
  fun parse() {
    val message = "Temporary Redirect"
    val version = 1
    val code = 200
    val statusLine = parse("HTTP/1.$version $code $message")
    assertThat(statusLine.message).isEqualTo(message)
    assertThat(statusLine.protocol).isEqualTo(Protocol.HTTP_1_1)
    assertThat(statusLine.code).isEqualTo(code)
  }

  @Test