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()
-
Constructor Details
-
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
-