java.lang.Object
org.elasticsearch.transport.InboundPipeline
- All Implemented Interfaces:
Closeable,AutoCloseable,Releasable
-
Constructor Summary
ConstructorsConstructorDescriptionInboundPipeline(StatsTracker statsTracker, LongSupplier relativeTimeInMillis, InboundDecoder decoder, InboundAggregator aggregator, BiConsumer<TcpChannel, InboundMessage> messageHandler) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voidhandleBytes(TcpChannel channel, ReleasableBytesReference reference) protected voidheaderReceived(Header header)
-
Constructor Details
-
InboundPipeline
public InboundPipeline(StatsTracker statsTracker, LongSupplier relativeTimeInMillis, InboundDecoder decoder, InboundAggregator aggregator, BiConsumer<TcpChannel, InboundMessage> messageHandler)
-
-
Method Details
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceReleasable
-
handleBytes
- Throws:
IOException
-
headerReceived
-