Class OioWorker
java.lang.Object
org.jboss.netty.channel.socket.oio.AbstractOioWorker<OioSocketChannel>
org.jboss.netty.channel.socket.oio.OioWorker
-
Field Summary
FieldsFields inherited from class org.jboss.netty.channel.socket.oio.AbstractOioWorker
channel, thread
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(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, Object message) Methods inherited from class org.jboss.netty.channel.socket.oio.AbstractOioWorker
close, executeInIoThread, isIoThread, setInterestOps
-
Field Details
-
SOCKET_CLOSED_MESSAGE
-
-
Constructor Details
-
OioWorker
OioWorker(OioSocketChannel channel)
-
-
Method Details
-
run
public void run()- Specified by:
run
in interfaceRunnable
- Overrides:
run
in classAbstractOioWorker<OioSocketChannel>
-
process
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:
IOException
-
write
-