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

Constructor Summary

Constructors

Constructor	Description
NioClientSocketPipelineSink(BossPool<NioClientBoss> bossPool)

Method Summary

Modifier and Type	Method	Description
private static void	bind(NioClientSocketChannel channel, ChannelFuture future, SocketAddress localAddress)
private void	connect(NioClientSocketChannel channel, ChannelFuture cf, 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 AbstractNioChannelSink

execute, isFireExceptionCaughtLater

Methods inherited from class AbstractChannelSink

exceptionCaught

Methods inherited from class Object

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

Field Details

logger

static final InternalLogger logger

bossPool

private final BossPool<NioClientBoss> bossPool

Constructor Details

NioClientSocketPipelineSink

NioClientSocketPipelineSink(BossPool<NioClientBoss> bossPool)

Method Details

eventSunk

public void eventSunk(ChannelPipeline pipeline,
 ChannelEvent e)
               throws Exception

Description copied from interface: ChannelSink

Invoked by ChannelPipeline when a downstream ChannelEvent has reached its terminal (the head of the pipeline).

Throws:

Exception

bind

private static void bind(NioClientSocketChannel channel,
 ChannelFuture future,
 SocketAddress localAddress)

connect

private void connect(NioClientSocketChannel channel,
 ChannelFuture cf,
 SocketAddress remoteAddress)

nextBoss

private NioClientBoss nextBoss()