Package org.elasticsearch.transport
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 Summary
Constructors Constructor Description InboundMessage(Header header, boolean isPing)
InboundMessage(Header header, java.lang.Exception exception)
InboundMessage(Header header, ReleasableBytesReference content, Releasable breakerRelease)
-
Method Summary
Modifier and Type Method Description void
close()
int
getContentLength()
java.lang.Exception
getException()
Header
getHeader()
boolean
isPing()
boolean
isShortCircuit()
StreamInput
openOrGetStreamInput()
Releasable
takeBreakerReleaseControl()
java.lang.String
toString()
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Constructor Details
-
InboundMessage
-
InboundMessage
-
InboundMessage
-
-
Method Details
-
getHeader
-
getContentLength
public int getContentLength() -
getException
public java.lang.Exception getException() -
isPing
public boolean isPing() -
isShortCircuit
public boolean isShortCircuit() -
takeBreakerReleaseControl
-
openOrGetStreamInput
- Throws:
java.io.IOException
-
close
public void close()- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceReleasable
-
toString
public java.lang.String toString()- Overrides:
toString
in classjava.lang.Object
-