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.
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).
io_uring is a high I/O performance scalable interface for fully
asynchronous Linux syscalls.
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, java.lang.String baseName, java.lang.String name, ChannelHandler handler) Deprecated.ChannelPipeline.addAfter(java.lang.String baseName, java.lang.String name, ChannelHandler handler) Inserts aChannelHandlerafter an existing handler of this pipeline.final ChannelPipelineDefaultChannelPipeline.addAfter(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addAfter(java.lang.String baseName, java.lang.String name, ChannelHandler handler) ChannelPipeline.addBefore(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler) Deprecated.ChannelPipeline.addBefore(java.lang.String baseName, java.lang.String name, ChannelHandler handler) Inserts aChannelHandlerbefore an existing handler of this pipeline.final ChannelPipelineDefaultChannelPipeline.addBefore(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addBefore(java.lang.String baseName, java.lang.String name, ChannelHandler handler) ChannelPipeline.addFirst(ChannelHandler... handlers) InsertsChannelHandlers at the first position of this pipeline.ChannelPipeline.addFirst(EventExecutorGroup group, ChannelHandler... handlers) Deprecated.ChannelPipeline.addFirst(EventExecutorGroup group, java.lang.String name, ChannelHandler handler) Deprecated.ChannelPipeline.addFirst(java.lang.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, java.lang.String name, ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addFirst(java.lang.String name, ChannelHandler handler) ChannelPipeline.addLast(ChannelHandler... handlers) InsertsChannelHandlers at the last position of this pipeline.ChannelPipeline.addLast(EventExecutorGroup group, ChannelHandler... handlers) Deprecated.ChannelPipeline.addLast(EventExecutorGroup group, java.lang.String name, ChannelHandler handler) Deprecated.ChannelPipeline.addLast(java.lang.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, java.lang.String name, ChannelHandler handler) final ChannelPipelineDefaultChannelPipeline.addLast(java.lang.String name, ChannelHandler handler) ChannelPipeline.fireChannelActive()final ChannelPipelineDefaultChannelPipeline.fireChannelActive()ChannelPipeline.fireChannelInactive()final ChannelPipelineDefaultChannelPipeline.fireChannelInactive()ChannelPipeline.fireChannelRead(java.lang.Object msg) final ChannelPipelineDefaultChannelPipeline.fireChannelRead(java.lang.Object msg) ChannelPipeline.fireChannelReadComplete()final ChannelPipelineDefaultChannelPipeline.fireChannelReadComplete()ChannelPipeline.fireChannelRegistered()final ChannelPipelineDefaultChannelPipeline.fireChannelRegistered()ChannelPipeline.fireChannelUnregistered()final ChannelPipelineDefaultChannelPipeline.fireChannelUnregistered()ChannelPipeline.fireChannelWritabilityChanged()final ChannelPipelineDefaultChannelPipeline.fireChannelWritabilityChanged()ChannelPipeline.fireExceptionCaught(java.lang.Throwable cause) final ChannelPipelineDefaultChannelPipeline.fireExceptionCaught(java.lang.Throwable cause) ChannelPipeline.fireUserEventTriggered(java.lang.Object event) final ChannelPipelineDefaultChannelPipeline.fireUserEventTriggered(java.lang.Object event) ChannelPipeline.flush()final ChannelPipelineDefaultChannelPipeline.flush()private ChannelPipelineDefaultChannelPipeline.internalAdd(EventExecutorGroup group, java.lang.String name, ChannelHandler handler, java.lang.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, java.lang.String newName, ChannelHandler newHandler) Replaces the specifiedChannelHandlerwith a new handler in this pipeline.final ChannelPipelineDefaultChannelPipeline.replace(ChannelHandler oldHandler, java.lang.String newName, ChannelHandler newHandler) Methods in io.netty.channel with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprivate voidAbstractChannel.AbstractUnsafe.closeOutboundBufferForShutdown(ChannelPipeline pipeline, ChannelOutboundBuffer buffer, java.lang.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, java.lang.Throwable cause, boolean allDataRead, 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, java.lang.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, java.lang.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, java.lang.Throwable cause, boolean close, RecvByteBufAllocator.Handle allocHandle) Deprecated. -
Uses of ChannelPipeline in io.netty.channel.uring
Methods in io.netty.channel.uring with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprotected final voidAbstractIoUringStreamChannel.IoUringStreamUnsafe.handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean allDataRead, IoUringRecvByteAllocatorHandle allocHandle) private voidAbstractIoUringStreamChannel.IoUringStreamUnsafe.scheduleNextRead(ChannelPipeline pipeline, IoUringRecvByteAllocatorHandle allocHandle, boolean rearm, boolean completeRead) -
Uses of ChannelPipeline in io.netty.handler.codec
Methods in io.netty.handler.codec with parameters of type ChannelPipelineModifier and TypeMethodDescriptionprotected abstract java.lang.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 java.lang.ObjectHttpObjectAggregator.continueResponse(HttpMessage start, int maxContentLength, ChannelPipeline pipeline) protected java.lang.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 TypeMethodDescriptionprotected java.lang.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 java.lang.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 java.lang.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 java.lang.ObjectStompSubframeAggregator.newContinueResponse(StompHeadersSubframe start, int maxContentLength, ChannelPipeline pipeline)
ChannelPipeline.addAfter(String, String, ChannelHandler)