Class AbstractCodecEmbedder.EmbeddedChannelSink
java.lang.Object
org.jboss.netty.handler.codec.embedder.AbstractCodecEmbedder.EmbeddedChannelSink
- All Implemented Interfaces:
ChannelHandler, ChannelSink, ChannelUpstreamHandler
- Enclosing class:
AbstractCodecEmbedder<E>
private final class AbstractCodecEmbedder.EmbeddedChannelSink
extends Object
implements ChannelSink, ChannelUpstreamHandler
-
Nested Class Summary
Nested classes/interfaces inherited from interface ChannelHandler
ChannelHandler.Sharable -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoideventSunk(ChannelPipeline pipeline, ChannelEvent e) Invoked byChannelPipelinewhen a downstreamChannelEventhas reached its terminal (the head of the pipeline).voidexceptionCaught(ChannelPipeline pipeline, ChannelEvent e, ChannelPipelineException cause) Invoked byChannelPipelinewhen an exception was raised while one of itsChannelHandlers process aChannelEvent.execute(ChannelPipeline pipeline, Runnable task) Execute the givenRunnablelater in the io-thread.private voidvoidHandles the specified upstream event.
-
Constructor Details
-
EmbeddedChannelSink
EmbeddedChannelSink()
-
-
Method Details
-
handleUpstream
Description copied from interface:ChannelUpstreamHandlerHandles the specified upstream event.- Specified by:
handleUpstreamin interfaceChannelUpstreamHandler- Parameters:
ctx- the context object for this handlere- the upstream event to process or intercept
-
eventSunk
Description copied from interface:ChannelSinkInvoked byChannelPipelinewhen a downstreamChannelEventhas reached its terminal (the head of the pipeline).- Specified by:
eventSunkin interfaceChannelSink
-
handleEvent
-
exceptionCaught
public void exceptionCaught(ChannelPipeline pipeline, ChannelEvent e, ChannelPipelineException cause) throws Exception Description copied from interface:ChannelSinkInvoked byChannelPipelinewhen an exception was raised while one of itsChannelHandlers process aChannelEvent.- Specified by:
exceptionCaughtin interfaceChannelSink- Throws:
Exception
-
execute
Description copied from interface:ChannelSinkExecute the givenRunnablelater in the io-thread. Some implementation may not support this and just execute it directly.- Specified by:
executein interfaceChannelSink
-