Package 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:

Runnable, Worker

class OioWorker
extends AbstractOioWorker<OioSocketChannel>

Field Summary

Fields

Modifier and Type	Field	Description
private static final Pattern	SOCKET_CLOSED_MESSAGE

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

channel, thread

Constructor Summary

Constructors

Constructor	Description
OioWorker(OioSocketChannel channel)

Method Summary

Modifier and Type	Method	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, 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 Details

SOCKET_CLOSED_MESSAGE

private static final Pattern SOCKET_CLOSED_MESSAGE

Constructor Details

OioWorker

OioWorker(OioSocketChannel channel)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class AbstractOioWorker<OioSocketChannel>

process

boolean process()
         throws 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:

IOException

write

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