com.caucho.cloud.bam
Class HmuxQueue

java.lang.Object
  extended by com.caucho.bam.mailbox.MultiworkerMailbox
      extended by 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