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 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)
```