private int leaseState;

    /**
     * Create a lease break acknowledgment
     *
     * @param config configuration
     * @param leaseKey lease key
     * @param leaseState acknowledged lease state
     */
    public Smb2LeaseBreakAcknowledgment(Configuration config, Smb2LeaseKey leaseKey, int leaseState) {
        super(config, SMB2_OPLOCK_BREAK);
        this.leaseKey = leaseKey;

                    .execute()) {
                final Map<String, Object> contentMap = response.getContent(OpenSearchCurl.jsonParser());
                if (!Constants.TRUE.equalsIgnoreCase(contentMap.get("acknowledged").toString())) {
                    throw new DictionaryException("Failed to update " + dictFile.getPath());
                }
            } catch (final IOException e) {

            if (!createIndexResponse.isAcknowledged()) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to create next index (not acknowledged): index={}", indexName);
                }
                throw new SuggesterException("Failed to create next index (not acknowledged): " + indexName);
            }

        final CreateIndexResponse response =
                client.admin().indices().prepareCreate(indexName).addAlias(new Alias(aliasName)).execute().actionGet();
        assertTrue("Index creation should be acknowledged", response.isAcknowledged());

        final Suggester suggester = Suggester.builder().build(client, "test");

        // Use reflection to access private method

import jcifs.Configuration;
import jcifs.internal.SMBProtocolDecodingException;
import jcifs.internal.smb2.ServerMessageBlock2Response;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Set Info response message. This response acknowledges the successful
 * modification of file or security information.
 *
 * @author mbechler
 *
 */
public class Smb2SetInfoResponse extends ServerMessageBlock2Response {

    /**

        CreateIndexResponse createIndexResponse =
                client.admin().indices().prepareCreate(TEST_INDEX).setSettings(indexSettings).execute().actionGet();

        assertTrue(createIndexResponse.isAcknowledged());

        // Create suggest settings index
        Settings suggestIndexSettings = Settings.builder().put("number_of_shards", 1).put("number_of_replicas", 0).build();

import jcifs.Configuration;
import jcifs.internal.SMBProtocolDecodingException;
import jcifs.internal.smb2.ServerMessageBlock2Response;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Lock response message. This response acknowledges the successful
 * acquisition or release of byte-range locks.
 *
 * @author mbechler
 *
 */
public class Smb2LockResponse extends ServerMessageBlock2Response {

    /**

import jcifs.Configuration;
import jcifs.internal.SMBProtocolDecodingException;
import jcifs.internal.smb2.ServerMessageBlock2Response;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Logoff response message. This response acknowledges the termination of an SMB2 session.
 *
 * @author mbechler
 *
 */
public class Smb2LogoffResponse extends ServerMessageBlock2Response {

    /**

import jcifs.internal.SmbBasicFileInfo;
import jcifs.internal.smb2.ServerMessageBlock2Response;
import jcifs.internal.util.SMBUtil;
import jcifs.util.Hexdump;

/**
 * SMB2 Close response message. This response acknowledges the closing of a file
 * and provides final file attributes.
 *
 * @author mbechler
 *
 */
public class Smb2CloseResponse extends ServerMessageBlock2Response implements SmbBasicFileInfo {

                        .setSettings(loadIndexSettings(), XContentType.JSON)
                        .execute()
                        .actionGet(settings.getIndicesTimeout());
                if (!response.isAcknowledged()) {
                    throw new SuggestSettingsException("Failed to create " + actualIndex + "/" + type + " index.", e);
                }
                client.admin()
                        .cluster()