org.jboss.netty.channel.socket.nio

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 and Description
private BossPool<NioClientBoss>	bossPool
(package private) static InternalLogger	logger

Constructor Summary

Constructors

Constructor and Description
NioClientSocketPipelineSink(BossPool<NioClientBoss> bossPool)

Method Summary

Modifier and Type	Method and 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 by ChannelPipeline when a downstream ChannelEvent 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

Methods inherited from class java.lang.Object

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

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 by ChannelPipeline when a downstream ChannelEvent 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()