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 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 Description OioWorker(OioSocketChannel channel)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) boolean
process()
Process the incoming messages and also is responsible for callChannels.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
-
-
-
-
Constructor Detail
-
OioWorker
OioWorker(OioSocketChannel channel)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classAbstractOioWorker<OioSocketChannel>
-
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<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)
-
-