Package org.jboss.netty.channel.socket.oio

Class OioDatagramPipelineSink

java.lang.Object

org.jboss.netty.channel.AbstractChannelSink

org.jboss.netty.channel.socket.oio.AbstractOioChannelSink

org.jboss.netty.channel.socket.oio.OioDatagramPipelineSink

All Implemented Interfaces:

ChannelSink

class OioDatagramPipelineSink
extends AbstractOioChannelSink

Field Summary

Fields

Modifier and Type	Field	Description
private final ThreadNameDeterminer	determiner
private final Executor	workerExecutor

Constructor Summary

Constructors

Constructor	Description
OioDatagramPipelineSink(Executor workerExecutor, ThreadNameDeterminer determiner)

Method Summary

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

workerExecutor

private final Executor workerExecutor

determiner

private final ThreadNameDeterminer determiner

Constructor Details

OioDatagramPipelineSink

OioDatagramPipelineSink(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 void bind(OioDatagramChannel channel,
 ChannelFuture future,
 SocketAddress localAddress)

connect

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