Class OioClientSocketPipelineSink
- java.lang.Object
-
- org.jboss.netty.channel.AbstractChannelSink
-
- org.jboss.netty.channel.socket.oio.AbstractOioChannelSink
-
- org.jboss.netty.channel.socket.oio.OioClientSocketPipelineSink
-
- All Implemented Interfaces:
ChannelSink
class OioClientSocketPipelineSink extends AbstractOioChannelSink
-
-
Field Summary
Fields Modifier and Type Field Description private ThreadNameDeterminer
determiner
private java.util.concurrent.Executor
workerExecutor
-
Constructor Summary
Constructors Constructor Description OioClientSocketPipelineSink(java.util.concurrent.Executor workerExecutor, ThreadNameDeterminer determiner)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description private static void
bind(OioClientSocketChannel channel, ChannelFuture future, java.net.SocketAddress localAddress)
private void
connect(OioClientSocketChannel channel, ChannelFuture future, java.net.SocketAddress remoteAddress)
void
eventSunk(ChannelPipeline pipeline, ChannelEvent e)
Invoked byChannelPipeline
when a downstreamChannelEvent
has reached its terminal (the head of the pipeline).-
Methods inherited from class org.jboss.netty.channel.socket.oio.AbstractOioChannelSink
execute, isFireExceptionCaughtLater
-
Methods inherited from class org.jboss.netty.channel.AbstractChannelSink
exceptionCaught
-
-
-
-
Field Detail
-
workerExecutor
private final java.util.concurrent.Executor workerExecutor
-
determiner
private final ThreadNameDeterminer determiner
-
-
Constructor Detail
-
OioClientSocketPipelineSink
OioClientSocketPipelineSink(java.util.concurrent.Executor workerExecutor, ThreadNameDeterminer determiner)
-
-
Method Detail
-
eventSunk
public void eventSunk(ChannelPipeline pipeline, ChannelEvent e) throws java.lang.Exception
Description copied from interface:ChannelSink
Invoked byChannelPipeline
when a downstreamChannelEvent
has reached its terminal (the head of the pipeline).- Throws:
java.lang.Exception
-
bind
private static void bind(OioClientSocketChannel channel, ChannelFuture future, java.net.SocketAddress localAddress)
-
connect
private void connect(OioClientSocketChannel channel, ChannelFuture future, java.net.SocketAddress remoteAddress)
-
-