Class NioClientSocketPipelineSink
- java.lang.Object
-
- org.jboss.netty.channel.AbstractChannelSink
-
- org.jboss.netty.channel.socket.nio.AbstractNioChannelSink
-
- org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink
-
- All Implemented Interfaces:
ChannelSink
class NioClientSocketPipelineSink extends AbstractNioChannelSink
-
-
Field Summary
Fields Modifier and Type Field Description private BossPool<NioClientBoss>
bossPool
(package private) static InternalLogger
logger
-
Constructor Summary
Constructors Constructor Description NioClientSocketPipelineSink(BossPool<NioClientBoss> bossPool)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description private static void
bind(NioClientSocketChannel channel, ChannelFuture future, java.net.SocketAddress localAddress)
private void
connect(NioClientSocketChannel channel, ChannelFuture cf, java.net.SocketAddress remoteAddress)
void
eventSunk(ChannelPipeline pipeline, ChannelEvent e)
Invoked byChannelPipeline
when a downstreamChannelEvent
has reached its terminal (the head of the pipeline).private NioClientBoss
nextBoss()
-
Methods inherited from class org.jboss.netty.channel.socket.nio.AbstractNioChannelSink
execute, isFireExceptionCaughtLater
-
Methods inherited from class org.jboss.netty.channel.AbstractChannelSink
exceptionCaught
-
-
-
-
Field Detail
-
logger
static final InternalLogger logger
-
bossPool
private final BossPool<NioClientBoss> bossPool
-
-
Constructor Detail
-
NioClientSocketPipelineSink
NioClientSocketPipelineSink(BossPool<NioClientBoss> bossPool)
-
-
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(NioClientSocketChannel channel, ChannelFuture future, java.net.SocketAddress localAddress)
-
connect
private void connect(NioClientSocketChannel channel, ChannelFuture cf, java.net.SocketAddress remoteAddress)
-
nextBoss
private NioClientBoss nextBoss()
-
-