com.caucho.env.actor
Interface ActorProcessor<T>

All Known Implementing Classes:
AbstractActorProcessor, AbstractWorkerQueue, JournalWriteActor

public interface ActorProcessor<T>

Processes an actor item.


Method Summary
 java.lang.String getThreadName()
          Returns the current thread name.
 void onProcessComplete()
          Called when all items in the queue are processed.
 void onProcessStart()
          Called before items in the queue are processed.
 void process(T item)
          Process a single item.
 

Method Detail

getThreadName

java.lang.String getThreadName()
Returns the current thread name.


onProcessStart

void onProcessStart()
                    throws java.lang.Exception
Called before items in the queue are processed. This can be used to establish a context

Throws:
java.lang.Exception

process

void process(T item)
             throws java.lang.Exception
Process a single item.

Throws:
java.lang.Exception

onProcessComplete

void onProcessComplete()
                       throws java.lang.Exception
Called when all items in the queue are processed. This can be used to flush buffers.

Throws:
java.lang.Exception