Package org.elasticsearch.transport

Class InboundPipeline

org.elasticsearch.transport.InboundPipeline

All Implemented Interfaces:

, , org.elasticsearch.core.Releasable

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

Constructor Summary

Constructors

Constructor	Description
InboundPipeline(StatsTracker statsTracker, relativeTimeInMillis, InboundDecoder decoder, InboundAggregator aggregator, <TcpChannel,InboundMessage> messageHandler)
InboundPipeline(Version version, StatsTracker statsTracker, PageCacheRecycler recycler, relativeTimeInMillis, <CircuitBreaker> circuitBreaker, <,RequestHandlerRegistry<TransportRequest>> registryFunction, <TcpChannel,InboundMessage> messageHandler)

Method Summary

Modifier and Type	Method	Description
void	close()
void	doHandleBytes(TcpChannel channel, ReleasableBytesReference reference)
void	handleBytes(TcpChannel channel, ReleasableBytesReference reference)

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Details

InboundPipeline

public InboundPipeline(Version version,
 StatsTracker statsTracker,
 PageCacheRecycler recycler,
  relativeTimeInMillis,
 <CircuitBreaker> circuitBreaker,
 <,RequestHandlerRegistry<TransportRequest>> registryFunction,
 <TcpChannel,InboundMessage> messageHandler)

InboundPipeline

public InboundPipeline(StatsTracker statsTracker,
  relativeTimeInMillis,
 InboundDecoder decoder,
 InboundAggregator aggregator,
 <TcpChannel,InboundMessage> messageHandler)

Method Details

close

public void close()

Specified by:

in interface

Specified by:

in interface

Specified by:

close in interface org.elasticsearch.core.Releasable

handleBytes

public void handleBytes(TcpChannel channel,
 ReleasableBytesReference reference)
                 throws 

Throws:

doHandleBytes

public void doHandleBytes(TcpChannel channel,
 ReleasableBytesReference reference)
                   throws 

Throws: