Uses of Interface
io.netty.channel.ChannelPipeline
Packages that use ChannelPipeline
Package
Description
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
A virtual
Channel that helps wrapping a series of handlers to
unit test the handlers or use them in non-I/O context.Optimized transport for linux which uses EPOLL Edge-Triggered Mode
for maximal performance.
BSD specific transport.
NIO-based channel
API implementation - recommended for a large number of connections (>= 1000).
Old blocking I/O based channel API implementation - recommended for
a small number of connections (< 1000).
Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
Encoder, decoder and their related message types for HTTP.
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
Handlers for sending and receiving HTTP/2 frames.
Common superset of ascii and binary classes.
Encoder, decoder for Redis.
STOMP codec
-
Uses of ChannelPipeline in io.netty.channel
Classes in io.netty.channel that implement ChannelPipelineMethods in io.netty.channel that return ChannelPipelineModifier and TypeMethodDescriptionChannelPipeline.addAfter(EventExecutorGroup group, String baseName, String name, ChannelHandler handler) Inserts aChannelHandlerafter an existing handler of this pipeline.ChannelPipeline.addAfter(String baseName, String name, ChannelHandler handler) Inserts aChannelHandlerafter an existing handler of this pipeline.final ChannelPipelineDefaultChannelPipeline.addAfter(EventExecutorGroup group, String baseName, String name, ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addAfter(String baseName, String name, ChannelHandler handler) ChannelPipeline.addBefore(EventExecutorGroup group, String baseName, String name, ChannelHandler handler) Inserts aChannelHandlerbefore an existing handler of this pipeline.ChannelPipeline.addBefore(String baseName, String name, ChannelHandler handler) Inserts aChannelHandlerbefore an existing handler of this pipeline.final ChannelPipelineDefaultChannelPipeline.addBefore(EventExecutorGroup group, String baseName, String name, ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addBefore(String baseName, String name, ChannelHandler handler) ChannelPipeline.addFirst(ChannelHandler... handlers) InsertsChannelHandlers at the first position of this pipeline.ChannelPipeline.addFirst(EventExecutorGroup group, ChannelHandler... handlers) InsertsChannelHandlers at the first position of this pipeline.ChannelPipeline.addFirst(EventExecutorGroup group, String name, ChannelHandler handler) Inserts aChannelHandlerat the first position of this pipeline.ChannelPipeline.addFirst(String name, ChannelHandler handler) Inserts aChannelHandlerat the first position of this pipeline.final ChannelPipelineDefaultChannelPipeline.addFirst(ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addFirst(ChannelHandler... handlers) final ChannelPipelineDefaultChannelPipeline.addFirst(EventExecutorGroup executor, ChannelHandler... handlers) final ChannelPipelineDefaultChannelPipeline.addFirst(EventExecutorGroup group, String name, ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addFirst(String name, ChannelHandler handler) ChannelPipeline.addLast(ChannelHandler... handlers) InsertsChannelHandlers at the last position of this pipeline.ChannelPipeline.addLast(EventExecutorGroup group, ChannelHandler... handlers) InsertsChannelHandlers at the last position of this pipeline.ChannelPipeline.addLast(EventExecutorGroup group, String name, ChannelHandler handler) Appends aChannelHandlerat the last position of this pipeline.ChannelPipeline.addLast(String name, ChannelHandler handler) Appends aChannelHandlerat the last position of this pipeline.final ChannelPipelineDefaultChannelPipeline.addLast(ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addLast(ChannelHandler... handlers) final ChannelPipelineDefaultChannelPipeline.addLast(EventExecutorGroup executor, ChannelHandler... handlers) final ChannelPipelineDefaultChannelPipeline.addLast(EventExecutorGroup group, String name, ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addLast(String name, ChannelHandler handler) ChannelPipeline.fireChannelActive()final ChannelPipelineDefaultChannelPipeline.fireChannelActive()ChannelPipeline.fireChannelInactive()final ChannelPipelineDefaultChannelPipeline.fireChannelInactive()ChannelPipeline.fireChannelRead(Object msg) final ChannelPipelineDefaultChannelPipeline.fireChannelRead(Object msg) ChannelPipeline.fireChannelReadComplete()final ChannelPipelineDefaultChannelPipeline.fireChannelReadComplete()ChannelPipeline.fireChannelRegistered()final ChannelPipelineDefaultChannelPipeline.fireChannelRegistered()ChannelPipeline.fireChannelUnregistered()final ChannelPipelineDefaultChannelPipeline.fireChannelUnregistered()ChannelPipeline.fireChannelWritabilityChanged()final ChannelPipelineDefaultChannelPipeline.fireChannelWritabilityChanged()ChannelPipeline.fireExceptionCaught(Throwable cause) final ChannelPipelineDefaultChannelPipeline.fireExceptionCaught(Throwable cause) ChannelPipeline.fireUserEventTriggered(Object event) final ChannelPipelineDefaultChannelPipeline.fireUserEventTriggered(Object event) ChannelPipeline.flush()final ChannelPipelineDefaultChannelPipeline.flush()private ChannelPipelineDefaultChannelPipeline.internalAdd(EventExecutorGroup group, String name, ChannelHandler handler, String baseName, DefaultChannelPipeline.AddStrategy addStrategy) AbstractChannel.pipeline()AbstractChannelHandlerContext.pipeline()Channel.pipeline()Return the assignedChannelPipeline.ChannelHandlerContext.pipeline()Return the assignedChannelPipelineCombinedChannelDuplexHandler.DelegatingChannelHandlerContext.pipeline()final ChannelPipelineDefaultChannelPipeline.read()ChannelPipeline.remove(ChannelHandler handler) Removes the specifiedChannelHandlerfrom this pipeline.final ChannelPipelineDefaultChannelPipeline.remove(ChannelHandler handler) ChannelPipeline.replace(ChannelHandler oldHandler, String newName, ChannelHandler newHandler) Replaces the specifiedChannelHandlerwith a new handler in this pipeline.final ChannelPipelineDefaultChannelPipeline.replace(ChannelHandler oldHandler, String newName, ChannelHandler newHandler) Methods in io.netty.channel with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate voidAbstractChannel.AbstractUnsafe.closeOutboundBufferForShutdown(ChannelPipeline pipeline, ChannelOutboundBuffer buffer, Throwable cause) -
Uses of ChannelPipeline in io.netty.channel.embedded
Classes in io.netty.channel.embedded that implement ChannelPipeline -
Uses of ChannelPipeline in io.netty.channel.epoll
Methods in io.netty.channel.epoll with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate voidAbstractEpollStreamChannel.EpollStreamUnsafe.handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, EpollRecvByteAllocatorHandle allocHandle) private static voidEpollDatagramChannel.processPacket(ChannelPipeline pipeline, EpollRecvByteAllocatorHandle handle, int bytesRead, DatagramPacket packet) private static voidEpollDatagramChannel.processPacketList(ChannelPipeline pipeline, EpollRecvByteAllocatorHandle handle, int bytesRead, RecyclableArrayList packetList) -
Uses of ChannelPipeline in io.netty.channel.kqueue
Methods in io.netty.channel.kqueue with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate voidAbstractKQueueStreamChannel.KQueueStreamUnsafe.handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle) -
Uses of ChannelPipeline in io.netty.channel.nio
Methods in io.netty.channel.nio with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate voidAbstractNioByteChannel.NioByteUnsafe.closeOnRead(ChannelPipeline pipeline) private voidAbstractNioByteChannel.NioByteUnsafe.handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, RecvByteBufAllocator.Handle allocHandle) -
Uses of ChannelPipeline in io.netty.channel.oio
Methods in io.netty.channel.oio with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate voidAbstractOioByteChannel.closeOnRead(ChannelPipeline pipeline) Deprecated.private voidAbstractOioByteChannel.handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, RecvByteBufAllocator.Handle allocHandle) Deprecated. -
Uses of ChannelPipeline in io.netty.handler.codec
Methods in io.netty.handler.codec with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprotected abstract ObjectMessageAggregator.newContinueResponse(S start, int maxContentLength, ChannelPipeline pipeline) Returns the 'continue response' for the specified start message if necessary. -
Uses of ChannelPipeline in io.netty.handler.codec.http
Methods in io.netty.handler.codec.http with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate ObjectHttpObjectAggregator.continueResponse(HttpMessage start, int maxContentLength, ChannelPipeline pipeline) protected ObjectHttpObjectAggregator.newContinueResponse(HttpMessage start, int maxContentLength, ChannelPipeline pipeline) -
Uses of ChannelPipeline in io.netty.handler.codec.http.websocketx
Methods in io.netty.handler.codec.http.websocketx with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate static StringWebSocketServerProtocolHandshakeHandler.getWebSocketLocation(ChannelPipeline cp, HttpRequest req, String path) protected ObjectWebSocketFrameAggregator.newContinueResponse(WebSocketFrame start, int maxContentLength, ChannelPipeline pipeline) -
Uses of ChannelPipeline in io.netty.handler.codec.http2
Fields in io.netty.handler.codec.http2 declared as ChannelPipelineModifier and TypeFieldDescriptionprivate final ChannelPipelineAbstractHttp2StreamChannel.pipelineMethods in io.netty.handler.codec.http2 that return ChannelPipeline -
Uses of ChannelPipeline in io.netty.handler.codec.memcache
Methods in io.netty.handler.codec.memcache with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprotected ObjectAbstractMemcacheObjectAggregator.newContinueResponse(H start, int maxContentLength, ChannelPipeline pipeline) -
Uses of ChannelPipeline in io.netty.handler.codec.redis
Methods in io.netty.handler.codec.redis with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprotected ObjectRedisBulkStringAggregator.newContinueResponse(BulkStringHeaderRedisMessage start, int maxContentLength, ChannelPipeline pipeline) -
Uses of ChannelPipeline in io.netty.handler.codec.stomp
Methods in io.netty.handler.codec.stomp with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprotected ObjectStompSubframeAggregator.newContinueResponse(StompHeadersSubframe start, int maxContentLength, ChannelPipeline pipeline)