Package org.jboss.netty.channel
Class AbstractChannelSink
- java.lang.Object
-
- org.jboss.netty.channel.AbstractChannelSink
-
- All Implemented Interfaces:
ChannelSink
- Direct Known Subclasses:
AbstractNioChannelSink
,AbstractOioChannelSink
public abstract class AbstractChannelSink extends Object implements ChannelSink
A skeletalChannelSink
implementation.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractChannelSink()
Creates a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
exceptionCaught(ChannelPipeline pipeline, ChannelEvent event, ChannelPipelineException cause)
Sends anExceptionEvent
upstream with the specifiedcause
.ChannelFuture
execute(ChannelPipeline pipeline, Runnable task)
This implementation just directly callRunnable.run()
.protected boolean
isFireExceptionCaughtLater(ChannelEvent event, Throwable actualCause)
Returnstrue
if and only if the specifiedactualCause
, which was raised while handling the specifiedevent
, must trigger anexceptionCaught()
event in an I/O thread.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.jboss.netty.channel.ChannelSink
eventSunk
-
-
-
-
Method Detail
-
exceptionCaught
public void exceptionCaught(ChannelPipeline pipeline, ChannelEvent event, ChannelPipelineException cause) throws Exception
Sends anExceptionEvent
upstream with the specifiedcause
.- Specified by:
exceptionCaught
in interfaceChannelSink
- Parameters:
event
- theChannelEvent
which caused aChannelHandler
to raise an exceptioncause
- the exception raised by aChannelHandler
- Throws:
Exception
-
isFireExceptionCaughtLater
protected boolean isFireExceptionCaughtLater(ChannelEvent event, Throwable actualCause)
Returnstrue
if and only if the specifiedactualCause
, which was raised while handling the specifiedevent
, must trigger anexceptionCaught()
event in an I/O thread.- Parameters:
event
- the event which raised exceptionactualCause
- the raised exception
-
execute
public ChannelFuture execute(ChannelPipeline pipeline, Runnable task)
This implementation just directly callRunnable.run()
. Sub-classes should override this if they can handle it in a better way- Specified by:
execute
in interfaceChannelSink
-
-