Class InboundMessage

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

public class InboundMessage
extends java.lang.Object
implements Releasable
  • Constructor Details

    • InboundMessage

      public InboundMessage​(Header header, ReleasableBytesReference content, Releasable breakerRelease)
    • InboundMessage

      public InboundMessage​(Header header, java.lang.Exception exception)
    • InboundMessage

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

    • getHeader

      public Header getHeader()
    • getContentLength

      public int getContentLength()
    • getException

      public java.lang.Exception getException()
    • isPing

      public boolean isPing()
    • isShortCircuit

      public boolean isShortCircuit()
    • takeBreakerReleaseControl

      public Releasable takeBreakerReleaseControl()
    • openOrGetStreamInput

      public StreamInput openOrGetStreamInput() throws java.io.IOException
      Throws:
      java.io.IOException
    • 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 Releasable
    • toString

      public java.lang.String toString()
      Overrides:
      toString in class java.lang.Object