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, java.lang.AutoCloseable

public class HmuxQueue
extends MultiworkerMailbox

Queue of hmtp packets

Method Summary

Modifier and Type	Method and Description
void	close() Closes the mailbox
protected ActorProcessor<Packet>	createProcessor()
MessageStream	getConnErrorStream()

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

createWorker, enqueue, getActorStream, getAddress, getBroker, getCurrentTimeActual, getSize, 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

createProcessor

protected ActorProcessor<Packet> createProcessor()

Overrides:

createProcessor in class MultiworkerMailbox

getConnErrorStream

public MessageStream getConnErrorStream()

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

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class MultiworkerMailbox