org.jboss.netty.channel.socket.oio

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 and Description
private ThreadNameDeterminer	determiner
private java.util.concurrent.Executor	workerExecutor

Constructor Summary

Constructors

Constructor and Description
OioClientSocketPipelineSink(java.util.concurrent.Executor workerExecutor, ThreadNameDeterminer determiner)

Method Summary

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

Methods inherited from class java.lang.Object

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

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