Package org.opensearch.transport

Class FakeTcpChannel

java.lang.Object
org.opensearch.transport.FakeTcpChannel
All Implemented Interfaces:
java.io.Closeable, java.lang.AutoCloseable, org.opensearch.common.network.CloseableChannel, org.opensearch.transport.TcpChannel
public class FakeTcpChannel
extends java.lang.Object
implements org.opensearch.transport.TcpChannel

  • Nested Class Summary

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

    org.opensearch.transport.TcpChannel.ChannelStats

  • Constructor Summary

    Constructors 
    Constructor Description
    FakeTcpChannel()  
    FakeTcpChannel​(boolean isServer)  
    FakeTcpChannel​(boolean isServer, java.lang.String profile, java.util.concurrent.atomic.AtomicReference<org.opensearch.common.bytes.BytesReference> messageCaptor)  
    FakeTcpChannel​(boolean isServer, java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress)  
    FakeTcpChannel​(boolean isServer, java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress, java.lang.String profile, java.util.concurrent.atomic.AtomicReference<org.opensearch.common.bytes.BytesReference> messageCaptor)  
    FakeTcpChannel​(boolean isServer, java.util.concurrent.atomic.AtomicReference<org.opensearch.common.bytes.BytesReference> messageCaptor)  

  • Method Summary

    Modifier and Type Method Description
    void addCloseListener​(org.opensearch.action.ActionListener<java.lang.Void> listener)  
    void addConnectListener​(org.opensearch.action.ActionListener<java.lang.Void> listener)  
    void close()  
    org.opensearch.transport.TcpChannel.ChannelStats getChannelStats()  
    java.util.concurrent.atomic.AtomicReference<org.opensearch.action.ActionListener<java.lang.Void>> getListenerCaptor()  
    java.net.InetSocketAddress getLocalAddress()  
    java.util.concurrent.atomic.AtomicReference<org.opensearch.common.bytes.BytesReference> getMessageCaptor()  
    java.lang.String getProfile()  
    java.net.InetSocketAddress getRemoteAddress()  
    boolean isOpen()  
    boolean isServerChannel()  
    void sendMessage​(org.opensearch.common.bytes.BytesReference reference, org.opensearch.action.ActionListener<java.lang.Void> listener)  

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • FakeTcpChannel

      public FakeTcpChannel()

    • FakeTcpChannel

      public FakeTcpChannel​(boolean isServer)

    • FakeTcpChannel

      public FakeTcpChannel​(boolean isServer, java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress)

    • FakeTcpChannel

      public FakeTcpChannel​(boolean isServer, java.util.concurrent.atomic.AtomicReference<org.opensearch.common.bytes.BytesReference> messageCaptor)

    • FakeTcpChannel

      public FakeTcpChannel​(boolean isServer, java.lang.String profile, java.util.concurrent.atomic.AtomicReference<org.opensearch.common.bytes.BytesReference> messageCaptor)

    • FakeTcpChannel

      public FakeTcpChannel​(boolean isServer, java.net.InetSocketAddress localAddress, java.net.InetSocketAddress remoteAddress, java.lang.String profile, java.util.concurrent.atomic.AtomicReference<org.opensearch.common.bytes.BytesReference> messageCaptor)

  • Method Details

    • isServerChannel

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

    • getProfile

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

    • getLocalAddress

      public java.net.InetSocketAddress getLocalAddress()
      Specified by:
      getLocalAddress in interface org.opensearch.transport.TcpChannel

    • getRemoteAddress

      public java.net.InetSocketAddress getRemoteAddress()
      Specified by:
      getRemoteAddress in interface org.opensearch.transport.TcpChannel

    • sendMessage

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

    • addConnectListener

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

    • 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.common.network.CloseableChannel

    • addCloseListener

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

    • isOpen

      public boolean isOpen()
      Specified by:
      isOpen in interface org.opensearch.common.network.CloseableChannel

    • getChannelStats

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

    • getMessageCaptor

      public java.util.concurrent.atomic.AtomicReference<org.opensearch.common.bytes.BytesReference> getMessageCaptor()

    • getListenerCaptor

      public java.util.concurrent.atomic.AtomicReference<org.opensearch.action.ActionListener<java.lang.Void>> getListenerCaptor()