Class MockNioTransport.MockSocketChannel

java.lang.Object
org.opensearch.nio.NioChannel
org.opensearch.nio.NioSocketChannel
org.opensearch.transport.nio.MockNioTransport.MockSocketChannel
All Implemented Interfaces:
Closeable, AutoCloseable, org.opensearch.common.network.CloseableChannel, org.opensearch.transport.TcpChannel
Enclosing class:
MockNioTransport
protected static class MockNioTransport.MockSocketChannel extends org.opensearch.nio.NioSocketChannel implements org.opensearch.transport.TcpChannel

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.opensearch.transport.TcpChannel

    org.opensearch.transport.TcpChannel.ChannelStats

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addCloseListener(org.opensearch.core.action.ActionListener<Void> listener)
     
    void
    addConnectListener(org.opensearch.core.action.ActionListener<Void> listener)
     
    void
    close()
     
    org.opensearch.transport.TcpChannel.ChannelStats
    getChannelStats()
     
    String
    getProfile()
     
    boolean
    isServerChannel()
     
    void
    sendMessage(org.opensearch.core.common.bytes.BytesReference reference, org.opensearch.core.action.ActionListener<Void> listener)
     

    Methods inherited from class org.opensearch.nio.NioSocketChannel

    addConnectListener, getContext, getLocalAddress, getRawChannel, getRemoteAddress, setContext, toString

    Methods inherited from class org.opensearch.nio.NioChannel

    addCloseListener, isOpen

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.opensearch.common.network.CloseableChannel

    isOpen

    Methods inherited from interface org.opensearch.transport.TcpChannel

    get, getLocalAddress, getRemoteAddress, sendMessage

  • Method Details

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.opensearch.common.network.CloseableChannel
      Overrides:
      close in class org.opensearch.nio.NioChannel

    • getProfile

      public String getProfile()
      Specified by:
      getProfile in interface org.opensearch.transport.TcpChannel

    • isServerChannel

      public boolean isServerChannel()
      Specified by:
      isServerChannel in interface org.opensearch.transport.TcpChannel

    • addCloseListener

      public void addCloseListener(org.opensearch.core.action.ActionListener<Void> listener)
      Specified by:
      addCloseListener in interface org.opensearch.common.network.CloseableChannel

    • addConnectListener

      public void addConnectListener(org.opensearch.core.action.ActionListener<Void> listener)
      Specified by:
      addConnectListener in interface org.opensearch.transport.TcpChannel

    • getChannelStats

      public org.opensearch.transport.TcpChannel.ChannelStats getChannelStats()
      Specified by:
      getChannelStats in interface org.opensearch.transport.TcpChannel

    • sendMessage

      public void sendMessage(org.opensearch.core.common.bytes.BytesReference reference, org.opensearch.core.action.ActionListener<Void> listener)
      Specified by:
      sendMessage in interface org.opensearch.transport.TcpChannel