Package org.elasticsearch.transport

Class InboundAggregator

org.elasticsearch.transport.InboundAggregator

All Implemented Interfaces:

, , org.elasticsearch.core.Releasable

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

Constructor Summary

Constructors

Constructor	Description
<CircuitBreaker> circuitBreaker, <,RequestHandlerRegistry<TransportRequest>> registryFunction)

Method Summary

Modifier and Type	Method	Description
void	aggregate(ReleasableBytesReference content)
void	close()
InboundMessage	finishAggregation()
void	headerReceived(Header header)
boolean	isAggregating()

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Details

InboundAggregator

public InboundAggregator(<CircuitBreaker> circuitBreaker,
 <,RequestHandlerRegistry<TransportRequest>> registryFunction)

Method Details

headerReceived

public void headerReceived(Header header)

aggregate

public void aggregate(ReleasableBytesReference content)

finishAggregation

public InboundMessage finishAggregation()
                                 throws 

Throws:

isAggregating

public boolean isAggregating()

close

public void close()

Specified by:

in interface

Specified by:

in interface

Specified by:

close in interface org.elasticsearch.core.Releasable