Package org.elasticsearch.transport

Class InboundMessage

org.elasticsearch.transport.InboundMessage

All Implemented Interfaces:

, , org.elasticsearch.core.Releasable

public class InboundMessage
extends 
implements org.elasticsearch.core.Releasable

Constructor Summary

Constructors

Constructor	Description
InboundMessage(Header header, boolean isPing)
InboundMessage(Header header, exception)
InboundMessage(Header header, ReleasableBytesReference content, org.elasticsearch.core.Releasable breakerRelease)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getContentLength()
	getException()
Header	getHeader()
boolean	isPing()
boolean	isShortCircuit()
StreamInput	openOrGetStreamInput()
org.elasticsearch.core.Releasable	takeBreakerReleaseControl()
	toString()

Methods inherited from class java.lang.

, , , , , , , , ,

Constructor Details

InboundMessage

public InboundMessage(Header header,
 ReleasableBytesReference content,
 org.elasticsearch.core.Releasable breakerRelease)

InboundMessage

public InboundMessage(Header header,
  exception)

InboundMessage

public InboundMessage(Header header,
 boolean isPing)

Method Details

getHeader

public Header getHeader()

getContentLength

public int getContentLength()

getException

public  getException()

isPing

public boolean isPing()

isShortCircuit

public boolean isShortCircuit()

takeBreakerReleaseControl

public org.elasticsearch.core.Releasable takeBreakerReleaseControl()

openOrGetStreamInput

public StreamInput openOrGetStreamInput()
                                 throws 

Throws:

close

public void close()

Specified by:

in interface

Specified by:

in interface

Specified by:

close in interface org.elasticsearch.core.Releasable

toString

public  toString()

Overrides:

in class