com.caucho.bam.broker
Class PassthroughBroker

java.lang.Object
  extended by com.caucho.bam.broker.AbstractBrokerStream
      extended by com.caucho.bam.broker.AbstractBroker
          extended by 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
PassthroughBroker()
           
PassthroughBroker(Mailbox mailbox)
           
 
Method Summary
 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, isClosed, removeMailbox
 
Methods inherited from class com.caucho.bam.broker.AbstractBrokerStream
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