Class DefaultChannelPipeline

java.lang.Object

io.netty.channel.DefaultChannelPipeline

All Implemented Interfaces:

ChannelInboundInvoker, ChannelOutboundInvoker, ChannelPipeline, java.lang.Iterable<java.util.Map.Entry<java.lang.String, ChannelHandler>>

Direct Known Subclasses:

EmbeddedChannel.EmbeddedChannelPipeline

public class DefaultChannelPipeline
extends java.lang.Object
implements ChannelPipeline

The default ChannelPipeline implementation. It is usually created by a Channel implementation when the Channel is created.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	DefaultChannelPipeline.AddStrategy
(package private) final class	DefaultChannelPipeline.HeadContext
private final class	DefaultChannelPipeline.PendingHandlerAddedTask
private static class	DefaultChannelPipeline.PendingHandlerCallback
private final class	DefaultChannelPipeline.PendingHandlerRemovedTask
(package private) final class	DefaultChannelPipeline.TailContext

Field Summary

Fields

Modifier and Type	Field	Description
private final Channel	channel
private java.util.Map<EventExecutorGroup, EventExecutor>	childExecutors
private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<DefaultChannelPipeline, MessageSizeEstimator.Handle>	ESTIMATOR
private MessageSizeEstimator.Handle	estimatorHandle
private boolean	firstRegistration
(package private) final DefaultChannelPipeline.HeadContext	head
private static final java.lang.String	HEAD_NAME
(package private) static final InternalLogger	logger
private static final FastThreadLocal<java.util.Map<java.lang.Class<?>, java.lang.String>>	nameCaches
private DefaultChannelPipeline.PendingHandlerCallback	pendingHandlerCallbackHead	This is the head of a linked list that is processed by callHandlerAddedForAllHandlers() and so process all the pending callHandlerAdded0(AbstractChannelHandlerContext).
private boolean	registered	Set to true once the AbstractChannel is registered.Once set to true the value will never change.
private final ChannelFuture	succeededFuture
(package private) final DefaultChannelPipeline.TailContext	tail
private static final java.lang.String	TAIL_NAME
private final boolean	touch
private final VoidChannelPromise	voidPromise

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultChannelPipeline(Channel channel)

Method Summary

Modifier and Type	Method	Description
final ChannelPipeline	addAfter(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler)	Inserts a ChannelHandler after an existing handler of this pipeline.
final ChannelPipeline	addAfter(java.lang.String baseName, java.lang.String name, ChannelHandler handler)	Inserts a ChannelHandler after an existing handler of this pipeline.
private static void	addAfter0(AbstractChannelHandlerContext ctx, AbstractChannelHandlerContext newCtx)
final ChannelPipeline	addBefore(EventExecutorGroup group, java.lang.String baseName, java.lang.String name, ChannelHandler handler)	Inserts a ChannelHandler before an existing handler of this pipeline.
final ChannelPipeline	addBefore(java.lang.String baseName, java.lang.String name, ChannelHandler handler)	Inserts a ChannelHandler before an existing handler of this pipeline.
private static void	addBefore0(AbstractChannelHandlerContext ctx, AbstractChannelHandlerContext newCtx)
final ChannelPipeline	addFirst(ChannelHandler handler)
final ChannelPipeline	addFirst(ChannelHandler... handlers)	Inserts ChannelHandlers at the first position of this pipeline.
final ChannelPipeline	addFirst(EventExecutorGroup executor, ChannelHandler... handlers)	Inserts ChannelHandlers at the first position of this pipeline.
final ChannelPipeline	addFirst(EventExecutorGroup group, java.lang.String name, ChannelHandler handler)	Inserts a ChannelHandler at the first position of this pipeline.
final ChannelPipeline	addFirst(java.lang.String name, ChannelHandler handler)	Inserts a ChannelHandler at the first position of this pipeline.
private void	addFirst0(AbstractChannelHandlerContext newCtx)
final ChannelPipeline	addLast(ChannelHandler handler)
final ChannelPipeline	addLast(ChannelHandler... handlers)	Inserts ChannelHandlers at the last position of this pipeline.
final ChannelPipeline	addLast(EventExecutorGroup executor, ChannelHandler... handlers)	Inserts ChannelHandlers at the last position of this pipeline.
final ChannelPipeline	addLast(EventExecutorGroup group, java.lang.String name, ChannelHandler handler)	Appends a ChannelHandler at the last position of this pipeline.
final ChannelPipeline	addLast(java.lang.String name, ChannelHandler handler)	Appends a ChannelHandler at the last position of this pipeline.
private void	addLast0(AbstractChannelHandlerContext newCtx)
private boolean	atomicRemoveFromHandlerList(AbstractChannelHandlerContext ctx)	Method is synchronized to make the handler removal from the double linked list atomic.
final ChannelFuture	bind(java.net.SocketAddress localAddress)	Request to bind to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelFuture	bind(java.net.SocketAddress localAddress, ChannelPromise promise)	Request to bind to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
private void	callHandlerAdded0(AbstractChannelHandlerContext ctx)
private void	callHandlerAddedForAllHandlers()
private void	callHandlerAddedInEventLoop(AbstractChannelHandlerContext newCtx, EventExecutor executor)
private void	callHandlerCallbackLater(AbstractChannelHandlerContext ctx, boolean added)
private void	callHandlerRemoved0(AbstractChannelHandlerContext ctx)
final Channel	channel()	Returns the Channel that this pipeline is attached to.
private void	checkDuplicateName(java.lang.String name)
private static void	checkMultiplicity(ChannelHandler handler)
private EventExecutor	childExecutor(EventExecutorGroup group)
final ChannelFuture	close()	Request to close the Channel and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelFuture	close(ChannelPromise promise)	Request to close the Channel and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelFuture	connect(java.net.SocketAddress remoteAddress)	Request to connect to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelFuture	connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)	Request to connect to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelFuture	connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)	Request to connect to the given SocketAddress while bind to the localAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelFuture	connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)	Request to connect to the given SocketAddress while bind to the localAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelHandlerContext	context(ChannelHandler handler)	Returns the context object of the specified ChannelHandler in this pipeline.
final ChannelHandlerContext	context(java.lang.Class<? extends ChannelHandler> handlerType)	Returns the context object of the ChannelHandler of the specified type in this pipeline.
final ChannelHandlerContext	context(java.lang.String name)	Returns the context object of the ChannelHandler with the specified name in this pipeline.
private AbstractChannelHandlerContext	context0(java.lang.String name)
protected void	decrementPendingOutboundBytes(long size)
final ChannelFuture	deregister()	Request to deregister from the previous assigned EventExecutor and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelFuture	deregister(ChannelPromise promise)	Request to deregister from the previous assigned EventExecutor and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
private void	destroy()	Removes all handlers from the pipeline one by one from tail (exclusive) to head (exclusive) to trigger handlerRemoved().
private void	destroyDown(java.lang.Thread currentThread, AbstractChannelHandlerContext ctx, boolean inEventLoop)
private void	destroyUp(AbstractChannelHandlerContext ctx, boolean inEventLoop)
final ChannelFuture	disconnect()	Request to disconnect from the remote peer and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
final ChannelFuture	disconnect(ChannelPromise promise)	Request to disconnect from the remote peer and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
(package private) final MessageSizeEstimator.Handle	estimatorHandle()
private java.lang.String	filterName(java.lang.String name, ChannelHandler handler)
final ChannelPipeline	fireChannelActive()	A Channel is active now, which means it is connected.
final ChannelPipeline	fireChannelInactive()	A Channel is inactive now, which means it is closed.
final ChannelPipeline	fireChannelRead(java.lang.Object msg)	A Channel received a message.
final ChannelPipeline	fireChannelReadComplete()	Triggers an ChannelInboundHandler.channelReadComplete(ChannelHandlerContext) event to the next ChannelInboundHandler in the ChannelPipeline.
final ChannelPipeline	fireChannelRegistered()	A Channel was registered to its EventLoop.
final ChannelPipeline	fireChannelUnregistered()	A Channel was unregistered from its EventLoop.
final ChannelPipeline	fireChannelWritabilityChanged()	Triggers an ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext) event to the next ChannelInboundHandler in the ChannelPipeline.
final ChannelPipeline	fireExceptionCaught(java.lang.Throwable cause)	A Channel received an Throwable in one of its inbound operations.
final ChannelPipeline	fireUserEventTriggered(java.lang.Object event)	A Channel received an user defined event.
final ChannelHandler	first()	Returns the first ChannelHandler in this pipeline.
final ChannelHandlerContext	firstContext()	Returns the context of the first ChannelHandler in this pipeline.
final ChannelPipeline	flush()	Request to flush all pending messages via this ChannelOutboundInvoker.
private java.lang.String	generateName(ChannelHandler handler)
private static java.lang.String	generateName0(java.lang.Class<?> handlerType)
final <T extends ChannelHandler> T	get(java.lang.Class<T> handlerType)	Returns the ChannelHandler of the specified type in this pipeline.
final ChannelHandler	get(java.lang.String name)	Returns the ChannelHandler with the specified name in this pipeline.
private AbstractChannelHandlerContext	getContextOrDie(ChannelHandler handler)
private AbstractChannelHandlerContext	getContextOrDie(java.lang.Class<? extends ChannelHandler> handlerType)
private AbstractChannelHandlerContext	getContextOrDie(java.lang.String name)
protected void	incrementPendingOutboundBytes(long size)
private ChannelPipeline	internalAdd(EventExecutorGroup group, java.lang.String name, ChannelHandler handler, java.lang.String baseName, DefaultChannelPipeline.AddStrategy addStrategy)
(package private) final void	invokeHandlerAddedIfNeeded()
private boolean	isLinked(AbstractChannelHandlerContext ctx)	Returns true if the given context is still linked into the pipeline.
final java.util.Iterator<java.util.Map.Entry<java.lang.String, ChannelHandler>>	iterator()
final ChannelHandler	last()	Returns the last ChannelHandler in this pipeline.
final ChannelHandlerContext	lastContext()	Returns the context of the last ChannelHandler in this pipeline.
final java.util.List<java.lang.String>	names()	Returns the List of the handler names.
private AbstractChannelHandlerContext	newContext(EventExecutorGroup group, java.lang.String name, ChannelHandler handler)
final ChannelFuture	newFailedFuture(java.lang.Throwable cause)	Create a new ChannelFuture which is marked as failed already.
final ChannelProgressivePromise	newProgressivePromise()	Return an new ChannelProgressivePromise
final ChannelPromise	newPromise()	Return a new ChannelPromise.
final ChannelFuture	newSucceededFuture()	Create a new ChannelFuture which is marked as succeeded already.
protected void	onUnhandledChannelWritabilityChanged()	Called once the ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext) event hit the end of the ChannelPipeline.
protected void	onUnhandledInboundChannelActive()	Called once the ChannelInboundHandler.channelActive(ChannelHandlerContext)event hit the end of the ChannelPipeline.
protected void	onUnhandledInboundChannelInactive()	Called once the ChannelInboundHandler.channelInactive(ChannelHandlerContext) event hit the end of the ChannelPipeline.
protected void	onUnhandledInboundChannelReadComplete()	Called once the ChannelInboundHandler.channelReadComplete(ChannelHandlerContext) event hit the end of the ChannelPipeline.
protected void	onUnhandledInboundException(java.lang.Throwable cause)	Called once a Throwable hit the end of the ChannelPipeline without been handled by the user in ChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable).
protected void	onUnhandledInboundMessage(ChannelHandlerContext ctx, java.lang.Object msg)	Called once a message hit the end of the ChannelPipeline without been handled by the user in ChannelInboundHandler.channelRead(ChannelHandlerContext, Object).
protected void	onUnhandledInboundMessage(java.lang.Object msg)	Called once a message hit the end of the ChannelPipeline without been handled by the user in ChannelInboundHandler.channelRead(ChannelHandlerContext, Object).
protected void	onUnhandledInboundUserEventTriggered(java.lang.Object evt)	Called once an user event hit the end of the ChannelPipeline without been handled by the user in ChannelInboundHandler.userEventTriggered(ChannelHandlerContext, Object).
final ChannelPipeline	read()	Request to Read data from the Channel into the first inbound buffer, triggers an ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) event if data was read, and triggers a channelReadComplete event so the handler can decide to continue reading.
private AbstractChannelHandlerContext	remove(AbstractChannelHandlerContext ctx)
final ChannelPipeline	remove(ChannelHandler handler)	Removes the specified ChannelHandler from this pipeline.
final <T extends ChannelHandler> T	remove(java.lang.Class<T> handlerType)	Removes the ChannelHandler of the specified type from this pipeline.
final ChannelHandler	remove(java.lang.String name)	Removes the ChannelHandler with the specified name from this pipeline.
final ChannelHandler	removeFirst()	Removes the first ChannelHandler in this pipeline.
final <T extends ChannelHandler> T	removeIfExists(ChannelHandler handler)
private <T extends ChannelHandler> T	removeIfExists(ChannelHandlerContext ctx)
final <T extends ChannelHandler> T	removeIfExists(java.lang.Class<T> handlerType)
final <T extends ChannelHandler> T	removeIfExists(java.lang.String name)
final ChannelHandler	removeLast()	Removes the last ChannelHandler in this pipeline.
private ChannelHandler	replace(AbstractChannelHandlerContext ctx, java.lang.String newName, ChannelHandler newHandler)
final ChannelPipeline	replace(ChannelHandler oldHandler, java.lang.String newName, ChannelHandler newHandler)	Replaces the specified ChannelHandler with a new handler in this pipeline.
final <T extends ChannelHandler> T	replace(java.lang.Class<T> oldHandlerType, java.lang.String newName, ChannelHandler newHandler)	Replaces the ChannelHandler of the specified type with a new handler in this pipeline.
final ChannelHandler	replace(java.lang.String oldName, java.lang.String newName, ChannelHandler newHandler)	Replaces the ChannelHandler of the specified name with a new handler in this pipeline.
private static void	replace0(AbstractChannelHandlerContext oldCtx, AbstractChannelHandlerContext newCtx)
final java.util.Map<java.lang.String, ChannelHandler>	toMap()	Converts this pipeline into an ordered Map whose keys are handler names and whose values are handlers.
final java.lang.String	toString()	Returns the String representation of this pipeline.
(package private) final java.lang.Object	touch(java.lang.Object msg, AbstractChannelHandlerContext next)
private boolean	tryRemove(AbstractChannelHandlerContext ctx)	Removes the given context from the pipeline and schedules the call of ChannelHandler.handlerRemoved(ChannelHandlerContext).
final ChannelPromise	voidPromise()	Return a special ChannelPromise which can be reused for different operations.
final ChannelFuture	write(java.lang.Object msg)	Request to write a message via this ChannelHandlerContext through the ChannelPipeline.
final ChannelFuture	write(java.lang.Object msg, ChannelPromise promise)	Request to write a message via this ChannelHandlerContext through the ChannelPipeline.
final ChannelFuture	writeAndFlush(java.lang.Object msg)	Shortcut for call ChannelOutboundInvoker.write(Object) and ChannelOutboundInvoker.flush().
final ChannelFuture	writeAndFlush(java.lang.Object msg, ChannelPromise promise)	Shortcut for call ChannelOutboundInvoker.write(Object, ChannelPromise) and ChannelOutboundInvoker.flush().

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

logger

static final InternalLogger logger

HEAD_NAME

private static final java.lang.String HEAD_NAME

TAIL_NAME

private static final java.lang.String TAIL_NAME

nameCaches

private static final FastThreadLocal<java.util.Map<java.lang.Class<?>, java.lang.String>> nameCaches

ESTIMATOR

private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<DefaultChannelPipeline, MessageSizeEstimator.Handle> ESTIMATOR

head

final DefaultChannelPipeline.HeadContext head

tail

final DefaultChannelPipeline.TailContext tail

channel

private final Channel channel

succeededFuture

private final ChannelFuture succeededFuture

voidPromise

private final VoidChannelPromise voidPromise

touch

private final boolean touch

childExecutors

private java.util.Map<EventExecutorGroup, EventExecutor> childExecutors

estimatorHandle

private volatile MessageSizeEstimator.Handle estimatorHandle

firstRegistration

private boolean firstRegistration

pendingHandlerCallbackHead

private DefaultChannelPipeline.PendingHandlerCallback pendingHandlerCallbackHead

This is the head of a linked list that is processed by callHandlerAddedForAllHandlers() and so process all the pending callHandlerAdded0(AbstractChannelHandlerContext).

We only keep the head because it is expected that the list is used infrequently and its size is small. Thus full iterations to do insertions is assumed to be a good compromised to saving memory and tail management complexity.

registered

private boolean registered

Set to true once the AbstractChannel is registered.Once set to true the value will never change.

Constructor Details

DefaultChannelPipeline

protected DefaultChannelPipeline(Channel channel)

Method Details

estimatorHandle

final MessageSizeEstimator.Handle estimatorHandle()

touch

final java.lang.Object touch(java.lang.Object msg,
 AbstractChannelHandlerContext next)

newContext

private AbstractChannelHandlerContext newContext(EventExecutorGroup group,
 java.lang.String name,
 ChannelHandler handler)

childExecutor

private EventExecutor childExecutor(EventExecutorGroup group)

channel

public final Channel channel()

Description copied from interface: ChannelPipeline

Returns the Channel that this pipeline is attached to.

Specified by:

channel in interface ChannelPipeline

Returns:

the channel. null if this pipeline is not attached yet.

addFirst

public final ChannelPipeline addFirst(java.lang.String name,
 ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler at the first position of this pipeline.

Specified by:

addFirst in interface ChannelPipeline

Parameters:

name - the name of the handler to insert first

handler - the handler to insert first

internalAdd

private ChannelPipeline internalAdd(EventExecutorGroup group,
 java.lang.String name,
 ChannelHandler handler,
 java.lang.String baseName,
 DefaultChannelPipeline.AddStrategy addStrategy)

addFirst

public final ChannelPipeline addFirst(EventExecutorGroup group,
 java.lang.String name,
 ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler at the first position of this pipeline.

Specified by:

addFirst in interface ChannelPipeline

Parameters:

group - the EventExecutorGroup which will be used to execute the ChannelHandler methods

name - the name of the handler to insert first

handler - the handler to insert first

addFirst0

private void addFirst0(AbstractChannelHandlerContext newCtx)

addLast

public final ChannelPipeline addLast(java.lang.String name,
 ChannelHandler handler)

Description copied from interface: ChannelPipeline

Appends a ChannelHandler at the last position of this pipeline.

Specified by:

addLast in interface ChannelPipeline

Parameters:

name - the name of the handler to append

handler - the handler to append

addLast

public final ChannelPipeline addLast(EventExecutorGroup group,
 java.lang.String name,
 ChannelHandler handler)

Description copied from interface: ChannelPipeline

Appends a ChannelHandler at the last position of this pipeline.

Specified by:

addLast in interface ChannelPipeline

Parameters:

group - the EventExecutorGroup which will be used to execute the ChannelHandler methods

name - the name of the handler to append

handler - the handler to append

addLast0

private void addLast0(AbstractChannelHandlerContext newCtx)

addBefore

public final ChannelPipeline addBefore(java.lang.String baseName,
 java.lang.String name,
 ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler before an existing handler of this pipeline.

Specified by:

addBefore in interface ChannelPipeline

Parameters:

baseName - the name of the existing handler

name - the name of the handler to insert before

handler - the handler to insert before

addBefore

public final ChannelPipeline addBefore(EventExecutorGroup group,
 java.lang.String baseName,
 java.lang.String name,
 ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler before an existing handler of this pipeline.

Specified by:

addBefore in interface ChannelPipeline

Parameters:

group - the EventExecutorGroup which will be used to execute the ChannelHandler methods

baseName - the name of the existing handler

name - the name of the handler to insert before

handler - the handler to insert before

addBefore0

private static void addBefore0(AbstractChannelHandlerContext ctx,
 AbstractChannelHandlerContext newCtx)

filterName

private java.lang.String filterName(java.lang.String name,
 ChannelHandler handler)

addAfter

public final ChannelPipeline addAfter(java.lang.String baseName,
 java.lang.String name,
 ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler after an existing handler of this pipeline.

Specified by:

addAfter in interface ChannelPipeline

Parameters:

baseName - the name of the existing handler

name - the name of the handler to insert after

handler - the handler to insert after

addAfter

public final ChannelPipeline addAfter(EventExecutorGroup group,
 java.lang.String baseName,
 java.lang.String name,
 ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler after an existing handler of this pipeline.

Specified by:

addAfter in interface ChannelPipeline

Parameters:

group - the EventExecutorGroup which will be used to execute the ChannelHandler methods

baseName - the name of the existing handler

name - the name of the handler to insert after

handler - the handler to insert after

addAfter0

private static void addAfter0(AbstractChannelHandlerContext ctx,
 AbstractChannelHandlerContext newCtx)

addFirst

public final ChannelPipeline addFirst(ChannelHandler handler)

addFirst

public final ChannelPipeline addFirst(ChannelHandler... handlers)

Description copied from interface: ChannelPipeline

Inserts ChannelHandlers at the first position of this pipeline.

Specified by:

addFirst in interface ChannelPipeline

Parameters:

handlers - the handlers to insert first

addFirst

public final ChannelPipeline addFirst(EventExecutorGroup executor,
 ChannelHandler... handlers)

Description copied from interface: ChannelPipeline

Inserts ChannelHandlers at the first position of this pipeline.

Specified by:

addFirst in interface ChannelPipeline

Parameters:

executor - the EventExecutorGroup which will be used to execute the ChannelHandlers methods.

handlers - the handlers to insert first

addLast

public final ChannelPipeline addLast(ChannelHandler handler)

addLast

public final ChannelPipeline addLast(ChannelHandler... handlers)

Description copied from interface: ChannelPipeline

Inserts ChannelHandlers at the last position of this pipeline.

Specified by:

addLast in interface ChannelPipeline

Parameters:

handlers - the handlers to insert last

addLast

public final ChannelPipeline addLast(EventExecutorGroup executor,
 ChannelHandler... handlers)

Description copied from interface: ChannelPipeline

Inserts ChannelHandlers at the last position of this pipeline.

Specified by:

addLast in interface ChannelPipeline

Parameters:

executor - the EventExecutorGroup which will be used to execute the ChannelHandlers methods.

handlers - the handlers to insert last

generateName

private java.lang.String generateName(ChannelHandler handler)

generateName0

private static java.lang.String generateName0(java.lang.Class<?> handlerType)

remove

public final ChannelPipeline remove(ChannelHandler handler)

Description copied from interface: ChannelPipeline

Removes the specified ChannelHandler from this pipeline.

Specified by:

remove in interface ChannelPipeline

Parameters:

handler - the ChannelHandler to remove

remove

public final ChannelHandler remove(java.lang.String name)

Description copied from interface: ChannelPipeline

Removes the ChannelHandler with the specified name from this pipeline.

Specified by:

remove in interface ChannelPipeline

Parameters:

name - the name under which the ChannelHandler was stored.

Returns:

the removed handler

remove

public final <T extends ChannelHandler> T remove(java.lang.Class<T> handlerType)

Description copied from interface: ChannelPipeline

Removes the ChannelHandler of the specified type from this pipeline.

Specified by:

remove in interface ChannelPipeline

Type Parameters:

T - the type of the handler

Parameters:

handlerType - the type of the handler

Returns:

the removed handler

removeIfExists

public final <T extends ChannelHandler> T removeIfExists(java.lang.String name)

removeIfExists

public final <T extends ChannelHandler> T removeIfExists(java.lang.Class<T> handlerType)

removeIfExists

public final <T extends ChannelHandler> T removeIfExists(ChannelHandler handler)

removeIfExists

private <T extends ChannelHandler> T removeIfExists(ChannelHandlerContext ctx)

remove

private AbstractChannelHandlerContext remove(AbstractChannelHandlerContext ctx)

tryRemove

private boolean tryRemove(AbstractChannelHandlerContext ctx)

Removes the given context from the pipeline and schedules the call of ChannelHandler.handlerRemoved(ChannelHandlerContext).

Returns:

false if the context was not part of the pipeline anymore, in which case nothing is done.

isLinked

private boolean isLinked(AbstractChannelHandlerContext ctx)

Returns true if the given context is still linked into the pipeline. A removed context keeps its prev and next pointers (and a replaced context points to its replacement), so the check must be done by looking at the neighbour.

atomicRemoveFromHandlerList

private boolean atomicRemoveFromHandlerList(AbstractChannelHandlerContext ctx)

Method is synchronized to make the handler removal from the double linked list atomic.

Returns:

false if the context was already removed or replaced, in which case the list is not modified.

removeFirst

public final ChannelHandler removeFirst()

Description copied from interface: ChannelPipeline

Removes the first ChannelHandler in this pipeline.

Specified by:

removeFirst in interface ChannelPipeline

Returns:

the removed handler

removeLast

public final ChannelHandler removeLast()

Description copied from interface: ChannelPipeline

Removes the last ChannelHandler in this pipeline.

Specified by:

removeLast in interface ChannelPipeline

Returns:

the removed handler

replace

public final ChannelPipeline replace(ChannelHandler oldHandler,
 java.lang.String newName,
 ChannelHandler newHandler)

Description copied from interface: ChannelPipeline

Replaces the specified ChannelHandler with a new handler in this pipeline.

Specified by:

replace in interface ChannelPipeline

Parameters:

oldHandler - the ChannelHandler to be replaced

newName - the name under which the replacement should be added

newHandler - the ChannelHandler which is used as replacement

Returns:

itself

replace

public final ChannelHandler replace(java.lang.String oldName,
 java.lang.String newName,
 ChannelHandler newHandler)

Description copied from interface: ChannelPipeline

Replaces the ChannelHandler of the specified name with a new handler in this pipeline.

Specified by:

replace in interface ChannelPipeline

Parameters:

oldName - the name of the ChannelHandler to be replaced

newName - the name under which the replacement should be added

newHandler - the ChannelHandler which is used as replacement

Returns:

the removed handler

replace

public final <T extends ChannelHandler> T replace(java.lang.Class<T> oldHandlerType,
 java.lang.String newName,
 ChannelHandler newHandler)

Description copied from interface: ChannelPipeline

Replaces the ChannelHandler of the specified type with a new handler in this pipeline.

Specified by:

replace in interface ChannelPipeline

Parameters:

oldHandlerType - the type of the handler to be removed

newName - the name under which the replacement should be added

newHandler - the ChannelHandler which is used as replacement

Returns:

the removed handler

replace

private ChannelHandler replace(AbstractChannelHandlerContext ctx,
 java.lang.String newName,
 ChannelHandler newHandler)

replace0

private static void replace0(AbstractChannelHandlerContext oldCtx,
 AbstractChannelHandlerContext newCtx)

checkMultiplicity

private static void checkMultiplicity(ChannelHandler handler)

callHandlerAdded0

private void callHandlerAdded0(AbstractChannelHandlerContext ctx)

callHandlerRemoved0

private void callHandlerRemoved0(AbstractChannelHandlerContext ctx)

invokeHandlerAddedIfNeeded

final void invokeHandlerAddedIfNeeded()

first

public final ChannelHandler first()

Description copied from interface: ChannelPipeline

Returns the first ChannelHandler in this pipeline.

Specified by:

first in interface ChannelPipeline

Returns:

the first handler. null if this pipeline is empty.

firstContext

public final ChannelHandlerContext firstContext()

Description copied from interface: ChannelPipeline

Returns the context of the first ChannelHandler in this pipeline.

Specified by:

firstContext in interface ChannelPipeline

Returns:

the context of the first handler. null if this pipeline is empty.

last

public final ChannelHandler last()

Description copied from interface: ChannelPipeline

Returns the last ChannelHandler in this pipeline.

Specified by:

last in interface ChannelPipeline

Returns:

the last handler. null if this pipeline is empty.

lastContext

public final ChannelHandlerContext lastContext()

Description copied from interface: ChannelPipeline

Returns the context of the last ChannelHandler in this pipeline.

Specified by:

lastContext in interface ChannelPipeline

Returns:

the context of the last handler. null if this pipeline is empty.

get

public final ChannelHandler get(java.lang.String name)

Description copied from interface: ChannelPipeline

Returns the ChannelHandler with the specified name in this pipeline.

Specified by:

get in interface ChannelPipeline

Returns:

the handler with the specified name. null if there's no such handler in this pipeline.

get

public final <T extends ChannelHandler> T get(java.lang.Class<T> handlerType)

Description copied from interface: ChannelPipeline

Returns the ChannelHandler of the specified type in this pipeline.

Specified by:

get in interface ChannelPipeline

Returns:

the handler of the specified handler type. null if there's no such handler in this pipeline.

context

public final ChannelHandlerContext context(java.lang.String name)

Description copied from interface: ChannelPipeline

Returns the context object of the ChannelHandler with the specified name in this pipeline.

Specified by:

context in interface ChannelPipeline

Returns:

the context object of the handler with the specified name. null if there's no such handler in this pipeline.

context

public final ChannelHandlerContext context(ChannelHandler handler)

Description copied from interface: ChannelPipeline

Returns the context object of the specified ChannelHandler in this pipeline.

Specified by:

context in interface ChannelPipeline

Returns:

the context object of the specified handler. null if there's no such handler in this pipeline.

context

public final ChannelHandlerContext context(java.lang.Class<? extends ChannelHandler> handlerType)

Description copied from interface: ChannelPipeline

Returns the context object of the ChannelHandler of the specified type in this pipeline.

Specified by:

context in interface ChannelPipeline

Returns:

the context object of the handler of the specified type. null if there's no such handler in this pipeline.

names

public final java.util.List<java.lang.String> names()

Description copied from interface: ChannelPipeline

Returns the List of the handler names.

Specified by:

names in interface ChannelPipeline

toMap

public final java.util.Map<java.lang.String, ChannelHandler> toMap()

Description copied from interface: ChannelPipeline

Converts this pipeline into an ordered Map whose keys are handler names and whose values are handlers.

Specified by:

toMap in interface ChannelPipeline

iterator

public final java.util.Iterator<java.util.Map.Entry<java.lang.String, ChannelHandler>> iterator()

Specified by:

iterator in interface java.lang.Iterable<java.util.Map.Entry<java.lang.String, ChannelHandler>>

toString

public final java.lang.String toString()

Returns the String representation of this pipeline.

Overrides:

toString in class java.lang.Object

fireChannelRegistered

public final ChannelPipeline fireChannelRegistered()

Description copied from interface: ChannelInboundInvoker

A Channel was registered to its EventLoop. This will result in having the ChannelInboundHandler.channelRegistered(ChannelHandlerContext) method called of the next ChannelInboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

fireChannelRegistered in interface ChannelInboundInvoker

Specified by:

fireChannelRegistered in interface ChannelPipeline

fireChannelUnregistered

public final ChannelPipeline fireChannelUnregistered()

Description copied from interface: ChannelInboundInvoker

A Channel was unregistered from its EventLoop. This will result in having the ChannelInboundHandler.channelUnregistered(ChannelHandlerContext) method called of the next ChannelInboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

fireChannelUnregistered in interface ChannelInboundInvoker

Specified by:

fireChannelUnregistered in interface ChannelPipeline

destroy

private void destroy()

Removes all handlers from the pipeline one by one from tail (exclusive) to head (exclusive) to trigger handlerRemoved(). Note that we traverse up the pipeline (destroyUp(AbstractChannelHandlerContext, boolean)) before traversing down (destroyDown(Thread, AbstractChannelHandlerContext, boolean)) so that the handlers are removed after all events are handled. See: https://github.com/netty/netty/issues/3156

destroyUp

private void destroyUp(AbstractChannelHandlerContext ctx,
 boolean inEventLoop)

destroyDown

private void destroyDown(java.lang.Thread currentThread,
 AbstractChannelHandlerContext ctx,
 boolean inEventLoop)

fireChannelActive

public final ChannelPipeline fireChannelActive()

Description copied from interface: ChannelInboundInvoker

A Channel is active now, which means it is connected. This will result in having the ChannelInboundHandler.channelActive(ChannelHandlerContext) method called of the next ChannelInboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

fireChannelActive in interface ChannelInboundInvoker

Specified by:

fireChannelActive in interface ChannelPipeline

fireChannelInactive

public final ChannelPipeline fireChannelInactive()

Description copied from interface: ChannelInboundInvoker

A Channel is inactive now, which means it is closed. This will result in having the ChannelInboundHandler.channelInactive(ChannelHandlerContext) method called of the next ChannelInboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

fireChannelInactive in interface ChannelInboundInvoker

Specified by:

fireChannelInactive in interface ChannelPipeline

fireExceptionCaught

public final ChannelPipeline fireExceptionCaught(java.lang.Throwable cause)

Description copied from interface: ChannelInboundInvoker

A Channel received an Throwable in one of its inbound operations. This will result in having the ChannelInboundHandler.exceptionCaught(ChannelHandlerContext, Throwable) method called of the next ChannelInboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

fireExceptionCaught in interface ChannelInboundInvoker

Specified by:

fireExceptionCaught in interface ChannelPipeline

fireUserEventTriggered

public final ChannelPipeline fireUserEventTriggered(java.lang.Object event)

Description copied from interface: ChannelInboundInvoker

A Channel received an user defined event. This will result in having the ChannelInboundHandler.userEventTriggered(ChannelHandlerContext, Object) method called of the next ChannelInboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

fireUserEventTriggered in interface ChannelInboundInvoker

Specified by:

fireUserEventTriggered in interface ChannelPipeline

fireChannelRead

public final ChannelPipeline fireChannelRead(java.lang.Object msg)

Description copied from interface: ChannelInboundInvoker

A Channel received a message. This will result in having the ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) method called of the next ChannelInboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

fireChannelRead in interface ChannelInboundInvoker

Specified by:

fireChannelRead in interface ChannelPipeline

fireChannelReadComplete

public final ChannelPipeline fireChannelReadComplete()

Description copied from interface: ChannelInboundInvoker

Triggers an ChannelInboundHandler.channelReadComplete(ChannelHandlerContext) event to the next ChannelInboundHandler in the ChannelPipeline.

Specified by:

fireChannelReadComplete in interface ChannelInboundInvoker

Specified by:

fireChannelReadComplete in interface ChannelPipeline

fireChannelWritabilityChanged

public final ChannelPipeline fireChannelWritabilityChanged()

Description copied from interface: ChannelInboundInvoker

Triggers an ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext) event to the next ChannelInboundHandler in the ChannelPipeline.

Specified by:

fireChannelWritabilityChanged in interface ChannelInboundInvoker

Specified by:

fireChannelWritabilityChanged in interface ChannelPipeline

bind

public final ChannelFuture bind(java.net.SocketAddress localAddress)

Description copied from interface: ChannelOutboundInvoker

Request to bind to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

This will result in having the ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

bind in interface ChannelOutboundInvoker

connect

public final ChannelFuture connect(java.net.SocketAddress remoteAddress)

Description copied from interface: ChannelOutboundInvoker

Request to connect to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

If the connection fails because of a connection timeout, the ChannelFuture will get failed with a ConnectTimeoutException. If it fails because of connection refused a ConnectException will be used.

This will result in having the ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

connect in interface ChannelOutboundInvoker

connect

public final ChannelFuture connect(java.net.SocketAddress remoteAddress,
 java.net.SocketAddress localAddress)

Description copied from interface: ChannelOutboundInvoker

Request to connect to the given SocketAddress while bind to the localAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

This will result in having the ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

connect in interface ChannelOutboundInvoker

disconnect

public final ChannelFuture disconnect()

Description copied from interface: ChannelOutboundInvoker

Request to disconnect from the remote peer and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

This will result in having the ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

disconnect in interface ChannelOutboundInvoker

close

public final ChannelFuture close()

Description copied from interface: ChannelOutboundInvoker

Request to close the Channel and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. After it is closed it is not possible to reuse it again.

This will result in having the ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

close in interface ChannelOutboundInvoker

deregister

public final ChannelFuture deregister()

Description copied from interface: ChannelOutboundInvoker

Request to deregister from the previous assigned EventExecutor and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

This will result in having the ChannelOutboundHandler.deregister(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

deregister in interface ChannelOutboundInvoker

flush

public final ChannelPipeline flush()

Description copied from interface: ChannelOutboundInvoker

Request to flush all pending messages via this ChannelOutboundInvoker.

Specified by:

flush in interface ChannelOutboundInvoker

Specified by:

flush in interface ChannelPipeline

bind

public final ChannelFuture bind(java.net.SocketAddress localAddress,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to bind to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelPromise will be notified.

This will result in having the ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

bind in interface ChannelOutboundInvoker

connect

public final ChannelFuture connect(java.net.SocketAddress remoteAddress,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to connect to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelFuture will be notified.

If the connection fails because of a connection timeout, the ChannelFuture will get failed with a ConnectTimeoutException. If it fails because of connection refused a ConnectException will be used.

This will result in having the ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

connect in interface ChannelOutboundInvoker

connect

public final ChannelFuture connect(java.net.SocketAddress remoteAddress,
 java.net.SocketAddress localAddress,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to connect to the given SocketAddress while bind to the localAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelPromise will be notified and also returned.

This will result in having the ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

connect in interface ChannelOutboundInvoker

disconnect

public final ChannelFuture disconnect(ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to disconnect from the remote peer and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelPromise will be notified.

This will result in having the ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

disconnect in interface ChannelOutboundInvoker

close

public final ChannelFuture close(ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to close the Channel and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. After it is closed it is not possible to reuse it again. The given ChannelPromise will be notified.

This will result in having the ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

close in interface ChannelOutboundInvoker

deregister

public final ChannelFuture deregister(ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to deregister from the previous assigned EventExecutor and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelPromise will be notified.

This will result in having the ChannelOutboundHandler.deregister(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

deregister in interface ChannelOutboundInvoker

read

public final ChannelPipeline read()

Description copied from interface: ChannelOutboundInvoker

Request to Read data from the Channel into the first inbound buffer, triggers an ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) event if data was read, and triggers a channelReadComplete event so the handler can decide to continue reading. If there's a pending read operation already, this method does nothing.

This will result in having the ChannelOutboundHandler.read(ChannelHandlerContext) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

read in interface ChannelOutboundInvoker

write

public final ChannelFuture write(java.lang.Object msg)

Description copied from interface: ChannelOutboundInvoker

Request to write a message via this ChannelHandlerContext through the ChannelPipeline. This method will not request to actual flush, so be sure to call ChannelOutboundInvoker.flush() once you want to request to flush all pending data to the actual transport.

Specified by:

write in interface ChannelOutboundInvoker

write

public final ChannelFuture write(java.lang.Object msg,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to write a message via this ChannelHandlerContext through the ChannelPipeline. This method will not request to actual flush, so be sure to call ChannelOutboundInvoker.flush() once you want to request to flush all pending data to the actual transport.

Specified by:

write in interface ChannelOutboundInvoker

writeAndFlush

public final ChannelFuture writeAndFlush(java.lang.Object msg,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Shortcut for call ChannelOutboundInvoker.write(Object, ChannelPromise) and ChannelOutboundInvoker.flush().

Specified by:

writeAndFlush in interface ChannelOutboundInvoker

writeAndFlush

public final ChannelFuture writeAndFlush(java.lang.Object msg)

Description copied from interface: ChannelOutboundInvoker

Shortcut for call ChannelOutboundInvoker.write(Object) and ChannelOutboundInvoker.flush().

Specified by:

writeAndFlush in interface ChannelOutboundInvoker

newPromise

public final ChannelPromise newPromise()

Description copied from interface: ChannelOutboundInvoker

Return a new ChannelPromise.

Specified by:

newPromise in interface ChannelOutboundInvoker

Specified by:

newPromise in interface ChannelPipeline

newProgressivePromise

public final ChannelProgressivePromise newProgressivePromise()

Description copied from interface: ChannelOutboundInvoker

Return an new ChannelProgressivePromise

Specified by:

newProgressivePromise in interface ChannelOutboundInvoker

Specified by:

newProgressivePromise in interface ChannelPipeline

newSucceededFuture

public final ChannelFuture newSucceededFuture()

Description copied from interface: ChannelOutboundInvoker

Create a new ChannelFuture which is marked as succeeded already. So Future.isSuccess() will return true. All FutureListener added to it will be notified directly. Also every call of blocking methods will just return without blocking.

Specified by:

newSucceededFuture in interface ChannelOutboundInvoker

newFailedFuture

public final ChannelFuture newFailedFuture(java.lang.Throwable cause)

Description copied from interface: ChannelOutboundInvoker

Create a new ChannelFuture which is marked as failed already. So Future.isSuccess() will return false. All FutureListener added to it will be notified directly. Also every call of blocking methods will just return without blocking.

Specified by:

newFailedFuture in interface ChannelOutboundInvoker

Specified by:

newFailedFuture in interface ChannelPipeline

voidPromise

public final ChannelPromise voidPromise()

Description copied from interface: ChannelOutboundInvoker

Return a special ChannelPromise which can be reused for different operations.

It's only supported to use it for ChannelOutboundInvoker.write(Object, ChannelPromise).

Be aware that the returned ChannelPromise will not support most operations and should only be used if you want to save an object allocation for every write operation. You will not be able to detect if the operation was complete, only if it failed as the implementation will call ChannelPipeline.fireExceptionCaught(Throwable) in this case.

Be aware this is an expert feature and should be used with care!

Specified by:

voidPromise in interface ChannelOutboundInvoker

checkDuplicateName

private void checkDuplicateName(java.lang.String name)

context0

private AbstractChannelHandlerContext context0(java.lang.String name)

getContextOrDie

private AbstractChannelHandlerContext getContextOrDie(java.lang.String name)

getContextOrDie

private AbstractChannelHandlerContext getContextOrDie(ChannelHandler handler)

getContextOrDie

private AbstractChannelHandlerContext getContextOrDie(java.lang.Class<? extends ChannelHandler> handlerType)

callHandlerAddedForAllHandlers

private void callHandlerAddedForAllHandlers()

callHandlerCallbackLater

private void callHandlerCallbackLater(AbstractChannelHandlerContext ctx,
 boolean added)

callHandlerAddedInEventLoop

private void callHandlerAddedInEventLoop(AbstractChannelHandlerContext newCtx,
 EventExecutor executor)

onUnhandledInboundException

protected void onUnhandledInboundException(java.lang.Throwable cause)

Called once a Throwable hit the end of the ChannelPipeline without been handled by the user in ChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable).

onUnhandledInboundChannelActive

protected void onUnhandledInboundChannelActive()

Called once the ChannelInboundHandler.channelActive(ChannelHandlerContext)event hit the end of the ChannelPipeline.

onUnhandledInboundChannelInactive

protected void onUnhandledInboundChannelInactive()

Called once the ChannelInboundHandler.channelInactive(ChannelHandlerContext) event hit the end of the ChannelPipeline.

onUnhandledInboundMessage

protected void onUnhandledInboundMessage(java.lang.Object msg)

Called once a message hit the end of the ChannelPipeline without been handled by the user in ChannelInboundHandler.channelRead(ChannelHandlerContext, Object). This method is responsible to call ReferenceCountUtil.release(Object) on the given msg at some point.

onUnhandledInboundMessage

protected void onUnhandledInboundMessage(ChannelHandlerContext ctx,
 java.lang.Object msg)

Called once a message hit the end of the ChannelPipeline without been handled by the user in ChannelInboundHandler.channelRead(ChannelHandlerContext, Object). This method is responsible to call ReferenceCountUtil.release(Object) on the given msg at some point.

onUnhandledInboundChannelReadComplete

protected void onUnhandledInboundChannelReadComplete()

Called once the ChannelInboundHandler.channelReadComplete(ChannelHandlerContext) event hit the end of the ChannelPipeline.

onUnhandledInboundUserEventTriggered

protected void onUnhandledInboundUserEventTriggered(java.lang.Object evt)

Called once an user event hit the end of the ChannelPipeline without been handled by the user in ChannelInboundHandler.userEventTriggered(ChannelHandlerContext, Object). This method is responsible to call ReferenceCountUtil.release(Object) on the given event at some point.

onUnhandledChannelWritabilityChanged

protected void onUnhandledChannelWritabilityChanged()

Called once the ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext) event hit the end of the ChannelPipeline.

incrementPendingOutboundBytes

protected void incrementPendingOutboundBytes(long size)

decrementPendingOutboundBytes

protected void decrementPendingOutboundBytes(long size)