java.lang.Object

org.elasticsearch.transport.InboundPipeline

All Implemented Interfaces:: java.io.Closeable, java.lang.AutoCloseable, Releasable

public class InboundPipeline
extends java.lang.Object
implements Releasable

Constructor Summary

Constructors
Constructor	Description
`InboundPipeline(StatsTracker statsTracker, java.util.function.LongSupplier relativeTimeInMillis, InboundDecoder decoder, InboundAggregator aggregator, java.util.function.BiConsumer<TcpChannel,InboundMessage> messageHandler)`
`InboundPipeline(Version version, StatsTracker statsTracker, PageCacheRecycler recycler, java.util.function.LongSupplier relativeTimeInMillis, java.util.function.Supplier<CircuitBreaker> circuitBreaker, java.util.function.Function<java.lang.String,RequestHandlerRegistry<TransportRequest>> registryFunction, java.util.function.BiConsumer<TcpChannel,InboundMessage> messageHandler)`

Method Summary

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait