org.jboss.netty.channel.socket.oio

Class OioDatagramWorker

java.lang.Object

org.jboss.netty.channel.socket.oio.AbstractOioWorker<OioDatagramChannel>

org.jboss.netty.channel.socket.oio.OioDatagramWorker

All Implemented Interfaces:

java.lang.Runnable, Worker

class OioDatagramWorker
extends AbstractOioWorker<OioDatagramChannel>

Field Summary

Fields inherited from class org.jboss.netty.channel.socket.oio.AbstractOioWorker

channel, thread

Constructor Summary

Constructors

Constructor and Description
OioDatagramWorker(OioDatagramChannel channel)

Method Summary

Modifier and Type	Method and Description
(package private) static void	disconnect(OioDatagramChannel channel, ChannelFuture future)
(package private) boolean	process() Process the incoming messages and also is responsible for call Channels.fireMessageReceived(Channel, Object) once a message was processed without errors.
(package private) static void	write(OioDatagramChannel channel, ChannelFuture future, java.lang.Object message, java.net.SocketAddress remoteAddress)

Methods inherited from class org.jboss.netty.channel.socket.oio.AbstractOioWorker

close, executeInIoThread, isIoThread, run, setInterestOps

Methods inherited from class java.lang.Object

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

Constructor Detail

OioDatagramWorker

OioDatagramWorker(OioDatagramChannel channel)

Method Detail

process

boolean process()
         throws java.io.IOException

Description copied from class: AbstractOioWorker

Process the incoming messages and also is responsible for call Channels.fireMessageReceived(Channel, Object) once a message was processed without errors.

Specified by:

process in class AbstractOioWorker<OioDatagramChannel>

Returns:

continue returns true as long as this worker should continue to try processing incoming messages

Throws:

java.io.IOException

write

static void write(OioDatagramChannel channel,
                  ChannelFuture future,
                  java.lang.Object message,
                  java.net.SocketAddress remoteAddress)

disconnect

static void disconnect(OioDatagramChannel channel,
                       ChannelFuture future)