Package org.elasticsearch.transport
Class InboundPipeline
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)
-
Constructor Details
-
InboundPipeline
public 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) -
InboundPipeline
public InboundPipeline(StatsTracker statsTracker, java.util.function.LongSupplier relativeTimeInMillis, InboundDecoder decoder, InboundAggregator aggregator, java.util.function.BiConsumer<TcpChannel,InboundMessage> messageHandler)
-
-
Method Details
-
close
public void close()- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceReleasable
-
handleBytes
public void handleBytes(TcpChannel channel, ReleasableBytesReference reference) throws java.io.IOException- Throws:
java.io.IOException
-
doHandleBytes
public void doHandleBytes(TcpChannel channel, ReleasableBytesReference reference) throws java.io.IOException- Throws:
java.io.IOException
-