com.caucho.bam.broker

Class PassthroughBroker

java.lang.Object

com.caucho.bam.broker.AbstractBrokerStream

com.caucho.bam.broker.AbstractBroker

com.caucho.bam.broker.PassthroughBroker

All Implemented Interfaces:

Broker, MessageStream

public class PassthroughBroker
extends AbstractBroker

Broker is the hub which routes messages to actors.

Constructor Summary

Constructors

Constructor and Description
PassthroughBroker()
PassthroughBroker(Mailbox mailbox)

Method Summary

Modifier and Type	Method and Description
void	close() Close the Broker
Mailbox	getMailbox(java.lang.String address) Returns the actor stream for the given address.
void	setMailbox(Mailbox mailbox)
java.lang.String	toString()

Methods inherited from class com.caucho.bam.broker.AbstractBroker

addMailbox, getAddress, getBroker, getBrokerMailbox, getQueueFullHandler, isClosed, removeMailbox, setQueueFullHandler

Methods inherited from class com.caucho.bam.broker.AbstractBrokerStream

getQueryErrorStream, message, messageError, query, queryError, queryResult

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.caucho.bam.stream.MessageStream

message, messageError, query, queryError, queryResult

Constructor Detail

PassthroughBroker

public PassthroughBroker()

PassthroughBroker

public PassthroughBroker(Mailbox mailbox)

Method Detail

getMailbox

public Mailbox getMailbox(java.lang.String address)

Description copied from class: AbstractBrokerStream

Returns the actor stream for the given address.

Specified by:

getMailbox in interface Broker

Overrides:

getMailbox in class AbstractBroker

Parameters:

address - the address of the mailbox

Returns:

the mailbox with the given address or null

setMailbox

public void setMailbox(Mailbox mailbox)

close

public void close()

Description copied from interface: Broker

Close the Broker

Specified by:

close in interface Broker

Overrides:

close in class AbstractBroker

toString

public java.lang.String toString()

Overrides:

toString in class AbstractBrokerStream