Package io.netty.channel.embedded
Class EmbeddedChannel.EmbeddedChannelPipeline
- java.lang.Object
-
- io.netty.channel.DefaultChannelPipeline
-
- io.netty.channel.embedded.EmbeddedChannel.EmbeddedChannelPipeline
-
- All Implemented Interfaces:
ChannelInboundInvoker
,ChannelOutboundInvoker
,ChannelPipeline
,java.lang.Iterable<java.util.Map.Entry<java.lang.String,ChannelHandler>>
- Enclosing class:
- EmbeddedChannel
private final class EmbeddedChannel.EmbeddedChannelPipeline extends DefaultChannelPipeline
-
-
Constructor Summary
Constructors Constructor Description EmbeddedChannelPipeline(EmbeddedChannel channel)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
onUnhandledInboundException(java.lang.Throwable cause)
Called once aThrowable
hit the end of theChannelPipeline
without been handled by the user inChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable)
.protected void
onUnhandledInboundMessage(ChannelHandlerContext ctx, java.lang.Object msg)
Called once a message hit the end of theChannelPipeline
without been handled by the user inChannelInboundHandler.channelRead(ChannelHandlerContext, Object)
.-
Methods inherited from class io.netty.channel.DefaultChannelPipeline
addAfter, addAfter, addBefore, addBefore, addFirst, addFirst, addFirst, addFirst, addFirst, addLast, addLast, addLast, addLast, addLast, bind, bind, channel, close, close, connect, connect, connect, connect, context, context, context, decrementPendingOutboundBytes, deregister, deregister, disconnect, disconnect, fireChannelActive, fireChannelInactive, fireChannelRead, fireChannelReadComplete, fireChannelRegistered, fireChannelUnregistered, fireChannelWritabilityChanged, fireExceptionCaught, fireUserEventTriggered, first, firstContext, flush, get, get, incrementPendingOutboundBytes, iterator, last, lastContext, names, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, onUnhandledChannelWritabilityChanged, onUnhandledInboundChannelActive, onUnhandledInboundChannelInactive, onUnhandledInboundChannelReadComplete, onUnhandledInboundMessage, onUnhandledInboundUserEventTriggered, read, remove, remove, remove, removeFirst, removeIfExists, removeIfExists, removeIfExists, removeLast, replace, replace, replace, toMap, toString, voidPromise, write, write, writeAndFlush, writeAndFlush
-
-
-
-
Constructor Detail
-
EmbeddedChannelPipeline
EmbeddedChannelPipeline(EmbeddedChannel channel)
-
-
Method Detail
-
onUnhandledInboundException
protected void onUnhandledInboundException(java.lang.Throwable cause)
Description copied from class:DefaultChannelPipeline
Called once aThrowable
hit the end of theChannelPipeline
without been handled by the user inChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable)
.- Overrides:
onUnhandledInboundException
in classDefaultChannelPipeline
-
onUnhandledInboundMessage
protected void onUnhandledInboundMessage(ChannelHandlerContext ctx, java.lang.Object msg)
Description copied from class:DefaultChannelPipeline
Called once a message hit the end of theChannelPipeline
without been handled by the user inChannelInboundHandler.channelRead(ChannelHandlerContext, Object)
. This method is responsible to callReferenceCountUtil.release(Object)
on the given msg at some point.- Overrides:
onUnhandledInboundMessage
in classDefaultChannelPipeline
-
-