com.caucho.cloud.bam

Class HmuxWorker

java.lang.Object

com.caucho.env.actor.AbstractActorProcessor<Packet>

com.caucho.cloud.bam.HmuxWorker

All Implemented Interfaces:

ActorProcessor<Packet>

public class HmuxWorker
extends AbstractActorProcessor<Packet>

Queue of hmtp packets

Method Summary

Modifier and Type	Method and Description
void	close()
java.lang.String	getThreadName() Returns the current thread name.
void	onProcessComplete() Called when all items in the queue are processed.
void	process(Packet packet) Sends a message to an agent
java.lang.String	toString()

Methods inherited from class com.caucho.env.actor.AbstractActorProcessor

onProcessStart

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

getThreadName

public java.lang.String getThreadName()

Description copied from class: AbstractActorProcessor

Returns the current thread name.

Specified by:

getThreadName in interface ActorProcessor<Packet>

Overrides:

getThreadName in class AbstractActorProcessor<Packet>

process

public void process(Packet packet)

Sends a message to an agent

Specified by:

process in interface ActorProcessor<Packet>

Specified by:

process in class AbstractActorProcessor<Packet>

Parameters:

to - the target agent's address

from - the source agent's address

value - the message payload

onProcessComplete

public void onProcessComplete()
                       throws java.lang.Exception

Description copied from class: AbstractActorProcessor

Called when all items in the queue are processed. This can be used to flush buffers.

Specified by:

onProcessComplete in interface ActorProcessor<Packet>

Overrides:

onProcessComplete in class AbstractActorProcessor<Packet>

Throws:

java.lang.Exception

close

public void close()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object