import org.opensearch.core.action.ActionListener;
import org.opensearch.index.seqno.SequenceNumbers;
import org.opensearch.search.SearchHit;
import org.opensearch.search.SearchHits;
import org.opensearch.transport.client.Client;

import jakarta.annotation.Resource;

/**
 * @param <ENTITY> The type of entity.
 * @param <CB> The type of condition-bean.
 * @author ESFlute (using FreeGen)
 */

import jcifs.internal.smb2.ServerMessageBlock2;
import jcifs.internal.smb2.ServerMessageBlock2Response;
import jcifs.internal.smb2.Smb2Constants;
import jcifs.internal.util.SMBUtil;
import jcifs.util.transport.Response;

/**
 * Test class for Smb2NegotiateResponse functionality
 */
@DisplayName("Smb2NegotiateResponse Tests")
class Smb2NegotiateResponseTest {

    private Configuration mockConfig;

	if err != nil {
		return err
	}

	if r.NotificationCfg.Token != "" {
		req.Header.Set("Authorization", r.NotificationCfg.Token)
	}

	clnt := http.Client{Transport: getRemoteInstanceTransport()}
	resp, err := clnt.Do(req)
	if err != nil {
		return err
	}

	xhttp.DrainBody(resp.Body)
	if resp.StatusCode != http.StatusOK {
		return errors.New(resp.Status)
	}

    }
}
```

### 6.3 Session Integration
```java
// In SmbSession.java
private PersistentHandleManager handleManager;

public SmbSession(CIFSContext context, SmbTransport transport) {
    // ... existing initialization ...
    
    if (context.getConfig().isUseDurableHandles()) {
        this.handleManager = new PersistentHandleManager(context);
    }
}

    /**
     * Enable port 139 failover
     *
     * Property {@code jcifs.smb.client.port139.enabled} (boolean, default false)
     *
     * @return whether to failover to legacy transport on port 139
     */
    boolean isPort139FailoverEnabled();

    /**
     *
     * Property {@code jcifs.smb.client.useUnicode} (boolean, default true)
     *

          <type>String</type>
        </field>
        <field>
          <name>configuration</name>
          <type>DOM</type>
          <description>
            Extra configuration for the transport layer.
          </description>
        </field>
      </fields>
    </class>
    <class>
      <name>Mirror</name>
      <version>1.0.0+</version>
      <superClass>IdentifiableBase</superClass>

    /**
     * Interval in milliseconds for checking channel health
     */
    protected int channelHealthCheckInterval;

    // RDMA configuration
    /**
     * Flag indicating whether RDMA transport should be used when available
     */
    protected boolean useRDMA;
    /**
     * RDMA provider implementation to use (e.g. "disni" or "tcp")
     */
    protected String rdmaProvider;
    /**

      return true
    }
  }

  /**
   * HTTP/2 can have both stream timeouts (due to a problem with a single stream) and connection
   * timeouts (due to a problem with the transport). When a stream times out we don't know whether
   * the problem impacts just one stream or the entire connection.
   *
   * To differentiate the two cases we ping the server when a stream times out. If the overall

import org.opensearch.action.bulk.BulkRequestBuilder;
import org.opensearch.action.index.IndexAction;
import org.opensearch.action.index.IndexRequestBuilder;
import org.opensearch.action.support.WriteRequest;
import org.opensearch.transport.client.Client;

public class SuggesterTest {
    static Suggester suggester;

    static OpenSearchRunner runner;

    @BeforeClass
    public static void beforeClass() throws Exception {

				} else {
					authZPluginCfg.URL = opaCfg.URL
					authZPluginCfg.AuthToken = opaCfg.AuthToken
					authZPluginCfg.Transport = opaCfg.Transport
					authZPluginCfg.CloseRespFn = opaCfg.CloseRespFn
					authZInit = true
				}
			}
			if authZInit {
				setGlobalAuthZPlugin(polplugin.New(authZPluginCfg))
			}
		}