com.caucho.env.actor

Interface ActorProcessor<T>

All Known Implementing Classes:

AbstractActorProcessor, AbstractWorkerQueue, HmuxWorker, JournalWriteActor

public interface ActorProcessor<T>

Processes an actor item.

Method Summary

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