Package org.elasticsearch.transport
Class InboundMessage
java.lang.Object
org.elasticsearch.transport.InboundMessage
- All Implemented Interfaces:
java.io.Closeable,java.lang.AutoCloseable,org.elasticsearch.common.lease.Releasable
public class InboundMessage
extends java.lang.Object
implements org.elasticsearch.common.lease.Releasable
-
Constructor Summary
Constructors Constructor Description InboundMessage(Header header, boolean isPing)InboundMessage(Header header, java.lang.Exception exception)InboundMessage(Header header, ReleasableBytesReference content, org.elasticsearch.common.lease.Releasable breakerRelease) -
Method Summary
Modifier and Type Method Description voidclose()intgetContentLength()java.lang.ExceptiongetException()HeadergetHeader()booleanisPing()booleanisShortCircuit()StreamInputopenOrGetStreamInput()org.elasticsearch.common.lease.ReleasabletakeBreakerReleaseControl()java.lang.StringtoString()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Constructor Details
-
InboundMessage
public InboundMessage(Header header, ReleasableBytesReference content, org.elasticsearch.common.lease.Releasable breakerRelease) -
InboundMessage
-
InboundMessage
-
-
Method Details
-
getHeader
-
getContentLength
public int getContentLength() -
getException
public java.lang.Exception getException() -
isPing
public boolean isPing() -
isShortCircuit
public boolean isShortCircuit() -
takeBreakerReleaseControl
public org.elasticsearch.common.lease.Releasable takeBreakerReleaseControl() -
openOrGetStreamInput
- Throws:
java.io.IOException
-
close
public void close()- Specified by:
closein interfacejava.lang.AutoCloseable- Specified by:
closein interfacejava.io.Closeable- Specified by:
closein interfaceorg.elasticsearch.common.lease.Releasable
-
toString
public java.lang.String toString()- Overrides:
toStringin classjava.lang.Object
-