|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.amp.broker.AbstractAmpBroker
public class AbstractAmpBroker
AmpRouter routes messages to mailboxes.
Constructor Summary | |
---|---|
AbstractAmpBroker()
|
Method Summary | |
---|---|
AmpActorRef |
addMailbox(java.lang.String address,
AmpMailbox mailbox)
Adds a mailbox (optional operation). |
void |
close()
Close the broker. |
AmpActorRef |
getActorRef(java.lang.String to)
Returns a mailbox for the given address, or null if the mailbox does not exist. |
AmpActorRef |
getBrokerActor()
Returns the mailbox to the router itself. |
void |
query(long id,
java.lang.String to,
java.lang.String from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args)
|
void |
removeMailbox(java.lang.String address,
AmpMailbox mailbox)
Removes a mailbox (optional operation). |
void |
reply(long id,
java.lang.String to,
java.lang.String from,
AmpEncoder encoder,
java.lang.Object result)
|
void |
send(java.lang.String to,
java.lang.String from,
AmpEncoder encoder,
java.lang.String methodName,
java.lang.Object... args)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AbstractAmpBroker()
Method Detail |
---|
public AmpActorRef getActorRef(java.lang.String to)
AmpBroker
getActorRef
in interface AmpBroker
to
- the address of the mailbox
public AmpActorRef addMailbox(java.lang.String address, AmpMailbox mailbox)
AmpBroker
addMailbox
in interface AmpBroker
public void removeMailbox(java.lang.String address, AmpMailbox mailbox)
AmpBroker
removeMailbox
in interface AmpBroker
public void close()
AmpBroker
close
in interface AmpBroker
public AmpActorRef getBrokerActor()
AmpBroker
getBrokerActor
in interface AmpBroker
public void send(java.lang.String to, java.lang.String from, AmpEncoder encoder, java.lang.String methodName, java.lang.Object... args)
send
in interface AmpBroker
public void query(long id, java.lang.String to, java.lang.String from, AmpEncoder encoder, java.lang.String methodName, java.lang.Object... args)
query
in interface AmpBroker
public void reply(long id, java.lang.String to, java.lang.String from, AmpEncoder encoder, java.lang.Object result)
reply
in interface AmpBroker
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |