Package org.jboss.netty.channel
Class AbstractChannelSink
java.lang.Object
org.jboss.netty.channel.AbstractChannelSink
- All Implemented Interfaces:
ChannelSink
- Direct Known Subclasses:
AbstractNioChannelSink
,AbstractOioChannelSink
,HttpTunnelingClientSocketPipelineSink
,LocalClientChannelSink
,LocalServerChannelSink
A skeletal
ChannelSink
implementation.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
exceptionCaught
(ChannelPipeline pipeline, ChannelEvent event, ChannelPipelineException cause) Sends anExceptionEvent
upstream with the specifiedcause
.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
-
Constructor Details
-
AbstractChannelSink
protected AbstractChannelSink()Creates a new instance.
-
-
Method Details
-
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
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
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
-