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 Description OioDatagramWorker(OioDatagramChannel channel)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) static void
disconnect(OioDatagramChannel channel, ChannelFuture future)
(package private) boolean
process()
Process the incoming messages and also is responsible for callChannels.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
-
-
-
-
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 callChannels.fireMessageReceived(Channel, Object)
once a message was processed without errors.- Specified by:
process
in classAbstractOioWorker<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)
-
-