org.jboss.netty.channel.socket.oio

Class OioWorker

java.lang.Object

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

org.jboss.netty.channel.socket.oio.OioWorker

All Implemented Interfaces:

java.lang.Runnable, Worker

class OioWorker
extends AbstractOioWorker<OioSocketChannel>

Field Summary

Fields

Modifier and Type	Field and Description
private static java.util.regex.Pattern	SOCKET_CLOSED_MESSAGE

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

channel, thread

Constructor Summary

Constructors

Constructor and Description
OioWorker(OioSocketChannel channel)

Method Summary

Modifier and Type	Method and Description
(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.
void	run()
(package private) static void	write(OioSocketChannel channel, ChannelFuture future, java.lang.Object message)

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

close, executeInIoThread, isIoThread, setInterestOps

Methods inherited from class java.lang.Object

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

Field Detail

SOCKET_CLOSED_MESSAGE

private static final java.util.regex.Pattern SOCKET_CLOSED_MESSAGE

Constructor Detail

OioWorker

OioWorker(OioSocketChannel channel)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class AbstractOioWorker<OioSocketChannel>

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<OioSocketChannel>

Returns:

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

Throws:

java.io.IOException

write

static void write(OioSocketChannel channel,
                  ChannelFuture future,
                  java.lang.Object message)