|
||||||||||
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
com.caucho.bam.broker.AbstractManagedBroker
public abstract class AbstractManagedBroker
Broker is the hub which routes messages to actors.
Constructor Summary | |
---|---|
AbstractManagedBroker()
|
Method Summary | |
---|---|
void |
addMailbox(java.lang.String address,
Mailbox mailbox)
Adds a mailbox. |
Agent |
createAgent(MessageStream actorStream)
Creates an agent |
Agent |
createAgent(MessageStream actorStream,
MailboxType mailboxType)
Creates an agent |
Mailbox |
createClient(Mailbox next,
java.lang.String uid,
java.lang.String resource)
|
protected Mailbox |
createMailbox(MessageStream actorStream,
MailboxType mailboxType)
|
protected Mailbox |
createMailbox(java.lang.String address,
MessageStream actorStream,
MailboxType mailboxType)
|
boolean |
isClosed()
Returns true if the broker has been closed |
void |
removeMailbox(Mailbox mailbox)
Removes a mailbox. |
Methods inherited from class com.caucho.bam.broker.AbstractBroker |
---|
close, getAddress, getBroker, getBrokerMailbox, getMailbox |
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.broker.Broker |
---|
close, getBrokerMailbox, getMailbox |
Methods inherited from interface com.caucho.bam.stream.MessageStream |
---|
getAddress, getBroker, message, messageError, query, queryError, queryResult |
Constructor Detail |
---|
public AbstractManagedBroker()
Method Detail |
---|
public void addMailbox(java.lang.String address, Mailbox mailbox)
addMailbox
in interface Broker
addMailbox
in interface ManagedBroker
addMailbox
in class AbstractBroker
public void removeMailbox(Mailbox mailbox)
removeMailbox
in interface Broker
removeMailbox
in interface ManagedBroker
removeMailbox
in class AbstractBroker
public Agent createAgent(MessageStream actorStream)
createAgent
in interface ManagedBroker
public Agent createAgent(MessageStream actorStream, MailboxType mailboxType)
createAgent
in interface ManagedBroker
protected Mailbox createMailbox(MessageStream actorStream, MailboxType mailboxType)
protected Mailbox createMailbox(java.lang.String address, MessageStream actorStream, MailboxType mailboxType)
public Mailbox createClient(Mailbox next, java.lang.String uid, java.lang.String resource)
createClient
in interface ManagedBroker
public boolean isClosed()
isClosed
in interface MessageStream
isClosed
in class AbstractBroker
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |