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 final ThreadNameDeterminer	determiner
private final Executor	workerExecutor

Constructor Summary

Constructors

Constructor	Description
OioClientSocketPipelineSink(Executor workerExecutor, ThreadNameDeterminer determiner)

Method Summary

Modifier and Type	Method	Description
private static void	bind(OioClientSocketChannel channel, ChannelFuture future, SocketAddress localAddress)
private void	connect(OioClientSocketChannel channel, ChannelFuture future, SocketAddress remoteAddress)
void	eventSunk(ChannelPipeline pipeline, ChannelEvent e)	Invoked by ChannelPipeline when a downstream ChannelEvent has reached its terminal (the head of the pipeline).

Methods inherited from class AbstractOioChannelSink

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

workerExecutor

private final Executor workerExecutor

determiner

private final ThreadNameDeterminer determiner

Constructor Details

OioClientSocketPipelineSink

OioClientSocketPipelineSink(Executor workerExecutor,
 ThreadNameDeterminer determiner)

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(OioClientSocketChannel channel,
 ChannelFuture future,
 SocketAddress localAddress)

connect

private void connect(OioClientSocketChannel channel,
 ChannelFuture future,
 SocketAddress remoteAddress)