Class DefaultChannelPipeline.DiscardingChannelSink

java.lang.Object

org.jboss.netty.channel.DefaultChannelPipeline.DiscardingChannelSink

All Implemented Interfaces:

ChannelSink

Enclosing class:

DefaultChannelPipeline

private static final class DefaultChannelPipeline.DiscardingChannelSink
extends Object
implements ChannelSink

Constructor Summary

Constructors

Constructor	Description
DiscardingChannelSink()

Method Summary

Modifier and Type	Method	Description
void	eventSunk(ChannelPipeline pipeline, ChannelEvent e)	Invoked by ChannelPipeline when a downstream ChannelEvent has reached its terminal (the head of the pipeline).
void	exceptionCaught(ChannelPipeline pipeline, ChannelEvent e, ChannelPipelineException cause)	Invoked by ChannelPipeline when an exception was raised while one of its ChannelHandlers process a ChannelEvent.
ChannelFuture	execute(ChannelPipeline pipeline, Runnable task)	Execute the given Runnable later in the io-thread.

Methods inherited from class Object

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

Constructor Details

DiscardingChannelSink

DiscardingChannelSink()

Method Details

eventSunk

public void eventSunk(ChannelPipeline pipeline,
 ChannelEvent e)

Description copied from interface: ChannelSink

Invoked by ChannelPipeline when a downstream ChannelEvent has reached its terminal (the head of the pipeline).

Specified by:

eventSunk in interface ChannelSink

exceptionCaught

public void exceptionCaught(ChannelPipeline pipeline,
 ChannelEvent e,
 ChannelPipelineException cause)
                     throws Exception

Description copied from interface: ChannelSink

Invoked by ChannelPipeline when an exception was raised while one of its ChannelHandlers process a ChannelEvent.

Specified by:

exceptionCaught in interface ChannelSink

Throws:

Exception

execute

public ChannelFuture execute(ChannelPipeline pipeline,
 Runnable task)

Description copied from interface: ChannelSink

Execute the given Runnable later in the io-thread. Some implementation may not support this and just execute it directly.

Specified by:

execute in interface ChannelSink