Package org.elasticsearch.transport

Class InboundMessage

java.lang.Object

org.elasticsearch.transport.InboundMessage

All Implemented Interfaces:

Closeable, AutoCloseable, Releasable

public class InboundMessage
extends Object
implements Releasable

Constructor Summary

Constructors

Constructor	Description
InboundMessage(Header header, boolean isPing)
InboundMessage(Header header, Exception exception)
InboundMessage(Header header, ReleasableBytesReference content, Releasable breakerRelease)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getContentLength()
Exception	getException()
Header	getHeader()
boolean	isPing()
boolean	isShortCircuit()
StreamInput	openOrGetStreamInput()
Releasable	takeBreakerReleaseControl()
String	toString()

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,
 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 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 Releasable

toString

public String toString()

Overrides:

toString in class Object