com.caucho.cloud.bam
Class HmuxQueue

java.lang.Object
  com.caucho.bam.mailbox.MultiworkerMailbox
      com.caucho.cloud.bam.HmuxQueue

All Implemented Interfaces:

Mailbox, MessageStream, java.io.Closeable

public class HmuxQueue
extends MultiworkerMailbox

Queue of hmtp packets

Method Summary

void	close() Closes the mailbox
void	dispatch(Packet packet) Sends a message to an agent

Methods inherited from class com.caucho.bam.mailbox.MultiworkerMailbox

createWorker, dequeue, enqueue, getActorStream, getAddress, getBroker, getCurrentTimeActual, getThreadMax, isClosed, isPacketAvailable, message, messageError, query, queryError, queryResult, toString

Methods inherited from class java.lang.Object

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

Method Detail

dispatch

public void dispatch(Packet packet)

Sends a message to an agent

Overrides:

dispatch in class MultiworkerMailbox

Parameters:

to - the target agent's address

from - the source agent's address

value - the message payload

close

public void close()

Description copied from interface: Mailbox

Closes the mailbox

Specified by:

close in interface Mailbox

Specified by:

close in interface java.io.Closeable

Overrides:

close in class MultiworkerMailbox