Package org.opensearch.test.transport

Class StubbableTransport.WrappedConnection

java.lang.Object
org.opensearch.test.transport.StubbableTransport.WrappedConnection
All Implemented Interfaces:
java.io.Closeable, java.lang.AutoCloseable, org.opensearch.transport.Transport.Connection
Enclosing class:
StubbableTransport
public class StubbableTransport.WrappedConnection
extends java.lang.Object
implements org.opensearch.transport.Transport.Connection

  • Method Summary

    Modifier and Type Method Description
    void addCloseListener​(org.opensearch.action.ActionListener<java.lang.Void> listener)  
    void close()  
    java.lang.Object getCacheKey()  
    org.opensearch.transport.Transport.Connection getConnection()  
    org.opensearch.cluster.node.DiscoveryNode getNode()  
    org.opensearch.Version getVersion()  
    boolean isClosed()  
    void sendRequest​(long requestId, java.lang.String action, org.opensearch.transport.TransportRequest request, org.opensearch.transport.TransportRequestOptions options)  

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • getNode

      public org.opensearch.cluster.node.DiscoveryNode getNode()
      Specified by:
      getNode in interface org.opensearch.transport.Transport.Connection

    • sendRequest

      public void sendRequest​(long requestId, java.lang.String action, org.opensearch.transport.TransportRequest request, org.opensearch.transport.TransportRequestOptions options) throws java.io.IOException, org.opensearch.transport.TransportException
      Specified by:
      sendRequest in interface org.opensearch.transport.Transport.Connection
      Throws:
      java.io.IOException
      org.opensearch.transport.TransportException

    • addCloseListener

      public void addCloseListener​(org.opensearch.action.ActionListener<java.lang.Void> listener)
      Specified by:
      addCloseListener in interface org.opensearch.transport.Transport.Connection

    • isClosed

      public boolean isClosed()
      Specified by:
      isClosed in interface org.opensearch.transport.Transport.Connection

    • getVersion

      public org.opensearch.Version getVersion()
      Specified by:
      getVersion in interface org.opensearch.transport.Transport.Connection

    • getCacheKey

      public java.lang.Object getCacheKey()
      Specified by:
      getCacheKey in interface org.opensearch.transport.Transport.Connection

    • close

      public void close()
      Specified by:
      close in interface java.lang.AutoCloseable
      Specified by:
      close in interface java.io.Closeable
      Specified by:
      close in interface org.opensearch.transport.Transport.Connection

    • getConnection

      public org.opensearch.transport.Transport.Connection getConnection()