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 aChannelHandler
after an existing handler of this pipeline.ChannelPipeline.addAfter
(String baseName, String name, ChannelHandler handler) Inserts aChannelHandler
after an existing handler of this pipeline.final ChannelPipeline
DefaultChannelPipeline.addAfter
(EventExecutorGroup group, String baseName, String name, ChannelHandler handler) final ChannelPipeline
DefaultChannelPipeline.addAfter
(String baseName, String name, ChannelHandler handler) ChannelPipeline.addBefore
(EventExecutorGroup group, String baseName, String name, ChannelHandler handler) Inserts aChannelHandler
before an existing handler of this pipeline.ChannelPipeline.addBefore
(String baseName, String name, ChannelHandler handler) Inserts aChannelHandler
before an existing handler of this pipeline.final ChannelPipeline
DefaultChannelPipeline.addBefore
(EventExecutorGroup group, String baseName, String name, ChannelHandler handler) final ChannelPipeline
DefaultChannelPipeline.addBefore
(String baseName, String name, ChannelHandler handler) ChannelPipeline.addFirst
(ChannelHandler... handlers) InsertsChannelHandler
s at the first position of this pipeline.ChannelPipeline.addFirst
(EventExecutorGroup group, ChannelHandler... handlers) InsertsChannelHandler
s at the first position of this pipeline.ChannelPipeline.addFirst
(EventExecutorGroup group, String name, ChannelHandler handler) Inserts aChannelHandler
at the first position of this pipeline.ChannelPipeline.addFirst
(String name, ChannelHandler handler) Inserts aChannelHandler
at the first position of this pipeline.final ChannelPipeline
DefaultChannelPipeline.addFirst
(ChannelHandler handler) final ChannelPipeline
DefaultChannelPipeline.addFirst
(ChannelHandler... handlers) final ChannelPipeline
DefaultChannelPipeline.addFirst
(EventExecutorGroup executor, ChannelHandler... handlers) final ChannelPipeline
DefaultChannelPipeline.addFirst
(EventExecutorGroup group, String name, ChannelHandler handler) final ChannelPipeline
DefaultChannelPipeline.addFirst
(String name, ChannelHandler handler) ChannelPipeline.addLast
(ChannelHandler... handlers) InsertsChannelHandler
s at the last position of this pipeline.ChannelPipeline.addLast
(EventExecutorGroup group, ChannelHandler... handlers) InsertsChannelHandler
s at the last position of this pipeline.ChannelPipeline.addLast
(EventExecutorGroup group, String name, ChannelHandler handler) Appends aChannelHandler
at the last position of this pipeline.ChannelPipeline.addLast
(String name, ChannelHandler handler) Appends aChannelHandler
at the last position of this pipeline.final ChannelPipeline
DefaultChannelPipeline.addLast
(ChannelHandler handler) final ChannelPipeline
DefaultChannelPipeline.addLast
(ChannelHandler... handlers) final ChannelPipeline
DefaultChannelPipeline.addLast
(EventExecutorGroup executor, ChannelHandler... handlers) final ChannelPipeline
DefaultChannelPipeline.addLast
(EventExecutorGroup group, String name, ChannelHandler handler) final ChannelPipeline
DefaultChannelPipeline.addLast
(String name, ChannelHandler handler) ChannelPipeline.fireChannelActive()
final ChannelPipeline
DefaultChannelPipeline.fireChannelActive()
ChannelPipeline.fireChannelInactive()
final ChannelPipeline
DefaultChannelPipeline.fireChannelInactive()
ChannelPipeline.fireChannelRead
(Object msg) final ChannelPipeline
DefaultChannelPipeline.fireChannelRead
(Object msg) ChannelPipeline.fireChannelReadComplete()
final ChannelPipeline
DefaultChannelPipeline.fireChannelReadComplete()
ChannelPipeline.fireChannelRegistered()
final ChannelPipeline
DefaultChannelPipeline.fireChannelRegistered()
ChannelPipeline.fireChannelUnregistered()
final ChannelPipeline
DefaultChannelPipeline.fireChannelUnregistered()
ChannelPipeline.fireChannelWritabilityChanged()
final ChannelPipeline
DefaultChannelPipeline.fireChannelWritabilityChanged()
ChannelPipeline.fireExceptionCaught
(Throwable cause) final ChannelPipeline
DefaultChannelPipeline.fireExceptionCaught
(Throwable cause) ChannelPipeline.fireUserEventTriggered
(Object event) final ChannelPipeline
DefaultChannelPipeline.fireUserEventTriggered
(Object event) ChannelPipeline.flush()
final ChannelPipeline
DefaultChannelPipeline.flush()
private ChannelPipeline
DefaultChannelPipeline.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 assignedChannelPipeline
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.pipeline()
final ChannelPipeline
DefaultChannelPipeline.read()
ChannelPipeline.remove
(ChannelHandler handler) Removes the specifiedChannelHandler
from this pipeline.final ChannelPipeline
DefaultChannelPipeline.remove
(ChannelHandler handler) ChannelPipeline.replace
(ChannelHandler oldHandler, String newName, ChannelHandler newHandler) Replaces the specifiedChannelHandler
with a new handler in this pipeline.final ChannelPipeline
DefaultChannelPipeline.replace
(ChannelHandler oldHandler, String newName, ChannelHandler newHandler) Methods in io.netty.channel with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate void
AbstractChannel.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 void
AbstractEpollStreamChannel.EpollStreamUnsafe.handleReadException
(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, EpollRecvByteAllocatorHandle allocHandle) private static void
EpollDatagramChannel.processPacket
(ChannelPipeline pipeline, EpollRecvByteAllocatorHandle handle, int bytesRead, DatagramPacket packet) private static void
EpollDatagramChannel.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 void
AbstractKQueueStreamChannel.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 void
AbstractNioByteChannel.NioByteUnsafe.closeOnRead
(ChannelPipeline pipeline) private void
AbstractNioByteChannel.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 void
AbstractOioByteChannel.closeOnRead
(ChannelPipeline pipeline) Deprecated.private void
AbstractOioByteChannel.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 Object
MessageAggregator.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 static Object
HttpObjectAggregator.continueResponse
(HttpMessage start, int maxContentLength, ChannelPipeline pipeline) protected Object
HttpObjectAggregator.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 String
WebSocketServerProtocolHandshakeHandler.getWebSocketLocation
(ChannelPipeline cp, HttpRequest req, String path) protected Object
WebSocketFrameAggregator.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 ChannelPipeline
AbstractHttp2StreamChannel.pipeline
Methods 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 Object
AbstractMemcacheObjectAggregator.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 Object
RedisBulkStringAggregator.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 Object
StompSubframeAggregator.newContinueResponse
(StompHeadersSubframe start, int maxContentLength, ChannelPipeline pipeline)