|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.bam.broker.AbstractBrokerStream
com.caucho.bam.broker.AbstractBroker
public abstract class AbstractBroker
Broker is the hub which routes messages to actors.
Constructor Summary | |
---|---|
AbstractBroker()
|
Method Summary | |
---|---|
void |
addMailbox(java.lang.String address,
Mailbox mailbox)
Adds a mailbox (optional operation). |
void |
close()
Close the Broker |
java.lang.String |
getAddress()
Returns the broker's address, i.e. |
Broker |
getBroker()
The broker returns itself for the broker. |
Mailbox |
getBrokerMailbox()
Returns a mailbox to the broker itself |
Mailbox |
getMailbox(java.lang.String address)
Returns the actor stream for the given address. |
boolean |
isClosed()
Returns true if the broker has been closed |
void |
removeMailbox(Mailbox mailbox)
Removes a mailbox (optional operation). |
Methods inherited from class com.caucho.bam.broker.AbstractBrokerStream |
---|
getQueryErrorStream, message, messageError, query, queryError, queryResult, toString |
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 |
---|
public AbstractBroker()
Method Detail |
---|
public java.lang.String getAddress()
getAddress
in interface MessageStream
getAddress
in class AbstractBrokerStream
public Broker getBroker()
getBroker
in interface MessageStream
public Mailbox getBrokerMailbox()
getBrokerMailbox
in interface Broker
public Mailbox getMailbox(java.lang.String address)
AbstractBrokerStream
getMailbox
in interface Broker
getMailbox
in class AbstractBrokerStream
address
- the address of the mailbox
public void addMailbox(java.lang.String address, Mailbox mailbox)
Broker
addMailbox
in interface Broker
public void removeMailbox(Mailbox mailbox)
Broker
removeMailbox
in interface Broker
public boolean isClosed()
isClosed
in interface MessageStream
isClosed
in class AbstractBrokerStream
public void close()
Broker
close
in interface Broker
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |