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 voidonUnhandledInboundException(java.lang.Throwable cause)Called once aThrowablehit the end of theChannelPipelinewithout been handled by the user inChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable).protected voidonUnhandledInboundMessage(ChannelHandlerContext ctx, java.lang.Object msg)Called once a message hit the end of theChannelPipelinewithout 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:DefaultChannelPipelineCalled once aThrowablehit the end of theChannelPipelinewithout been handled by the user inChannelHandler.exceptionCaught(ChannelHandlerContext, Throwable).- Overrides:
onUnhandledInboundExceptionin classDefaultChannelPipeline
-
onUnhandledInboundMessage
protected void onUnhandledInboundMessage(ChannelHandlerContext ctx, java.lang.Object msg)
Description copied from class:DefaultChannelPipelineCalled once a message hit the end of theChannelPipelinewithout 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:
onUnhandledInboundMessagein classDefaultChannelPipeline
-
-