Class InboundMessage

java.lang.Object
org.elasticsearch.transport.InboundMessage
All Implemented Interfaces:
Closeable, AutoCloseable, org.elasticsearch.core.Releasable

public class InboundMessage extends Object implements org.elasticsearch.core.Releasable
  • Constructor Details

    • InboundMessage

      public InboundMessage(Header header, ReleasableBytesReference content, org.elasticsearch.core.Releasable breakerRelease)
    • InboundMessage

      public InboundMessage(Header header, Exception exception)
    • InboundMessage

      public InboundMessage(Header header, boolean isPing)
  • Method Details

    • getHeader

      public Header getHeader()
    • getContentLength

      public int getContentLength()
    • getException

      public Exception getException()
    • isPing

      public boolean isPing()
    • isShortCircuit

      public boolean isShortCircuit()
    • takeBreakerReleaseControl

      public org.elasticsearch.core.Releasable takeBreakerReleaseControl()
    • openOrGetStreamInput

      public StreamInput openOrGetStreamInput() throws IOException
      Throws:
      IOException
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.elasticsearch.core.Releasable
    • toString

      public String toString()
      Overrides:
      toString in class Object