breakNotif.getLeaseKey(),
            breakNotif.getNewLeaseState()
        );
        
        sendAsync(ack);  // Send acknowledgment asynchronously
    }
    // ... handle other message types ...
}
```

## 7. Configuration

### 7.1 Configuration Properties
```java
// In PropertyConfiguration.java
public class PropertyConfiguration implements Configuration {

import org.codelibs.fess.query.parser.QueryParser;
import org.codelibs.fess.score.QueryRescorer;
import org.codelibs.fess.util.ComponentUtil;
import org.dbflute.optional.OptionalThing;
import org.lastaflute.core.message.UserMessages;
import org.lastaflute.web.util.LaRequestUtil;
import org.opensearch.action.search.SearchRequestBuilder;
import org.opensearch.index.query.BoolQueryBuilder;
import org.opensearch.index.query.QueryBuilder;

import jcifs.internal.smb2.Smb2Constants;
import jcifs.internal.smb2.lease.Smb2LeaseKey;
import jcifs.internal.util.SMBUtil;
import jcifs.util.Hexdump;

/**
 * SMB2 Create request message. This command is used to create or open a file or directory
 * on the server with specified access rights and sharing options.
 *
 * @author mbechler
 *
 */

        if (len == 0) {
            return; /* CRITICAL */
        }
        this.digest.update(input, offset, len);
        this.updates++;
    }

    /**
     * Finalize and return the calculated message digest
     *
     * @return calculated digest
     */
    public byte[] digest() {
        byte[] b = this.digest.digest();

        if (log.isTraceEnabled()) {
            log.trace("digest: ");

        // Mark as server->client response for realism
        SMBUtil.writeInt4(0x00000001, header, 16); // Flags
        // Command SMB2_CREATE (0x0005)
        SMBUtil.writeInt2(0x0005, header, 12);
        // Some message id
        SMBUtil.writeInt8(1L, header, 24);
        return header;
    }

    /**
     * Build a basic CREATE response body without create contexts.
     */

    val fakeAuthChallengeResponse =
      Response
        .Builder()
        .request(proxyConnectRequest)
        .protocol(Protocol.HTTP_1_1)
        .code(HttpURLConnection.HTTP_PROXY_AUTH)
        .message("Preemptive Authenticate")
        .sentRequestAtMillis(-1L)
        .receivedResponseAtMillis(-1L)
        .header("Proxy-Authenticate", "OkHttp-Preemptive")
        .build()

    val authenticatedRequest =

        assertEquals(16, hash1.length, "NT hash should be 16 bytes");
        assertEquals(16, hash2.length, "NT hash should be 16 bytes");
    }

    @Test
    @DisplayName("getNTHash: null password throws NPE with message")
    void testGetNTHash_null() {
        NullPointerException ex = assertThrows(NullPointerException.class, () -> NtlmUtil.getNTHash((String) null));
        assertEquals("Password parameter is required", ex.getMessage());
    }

            this.extendedSecurity = extendedSecurity;
        }

        @Override
        public void setSessionId(long sessionId) {
            this.sessionId = sessionId;
        }

        // Message interface methods
        @Override
        public boolean isRetainPayload() {
            return this.retainPayload;
        }

        @Override
        public void setRawPayload(byte[] rawPayload) {

     */
    public static class EngineObj {
        /**
         * Default constructor.
         */
        public EngineObj() {
            // Default constructor
        }

        /** Exception message if any error occurred */
        public String exception;
        /** Cluster health status */
        public String status;
        /** Number of in-flight fetch operations */
        public int numberOfInFlightFetch;

     * @param serverChallenge the server challenge bytes
     * @param clientChallenge the client challenge bytes
     * @param nanos1601 the timestamp in nanoseconds since 1601
     * @param avPairs the AV pairs from the Type 2 message
     * @return the calculated response
     */
    public static byte[] getNTLMv2Response(final byte[] responseKeyNT, final byte[] serverChallenge, final byte[] clientChallenge,