com.caucho.amp.broker
Interface AmpBroker

All Known Implementing Classes:
AbstractAmpBroker, HashMapAmpBroker

public interface AmpBroker

AmpRouter routes messages to mailboxes.


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 address)
          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)
           
 

Method Detail

getBrokerActor

AmpActorRef getBrokerActor()
Returns the mailbox to the router itself.


getActorRef

AmpActorRef getActorRef(java.lang.String address)
Returns a mailbox for the given address, or null if the mailbox does not exist.

Parameters:
address - the address of the mailbox
Returns:
the mailbox with the given address or null

send

void send(java.lang.String to,
          java.lang.String from,
          AmpEncoder encoder,
          java.lang.String methodName,
          java.lang.Object... args)

query

void query(long id,
           java.lang.String to,
           java.lang.String from,
           AmpEncoder encoder,
           java.lang.String methodName,
           java.lang.Object... args)

reply

void reply(long id,
           java.lang.String to,
           java.lang.String from,
           AmpEncoder encoder,
           java.lang.Object result)

addMailbox

AmpActorRef addMailbox(java.lang.String address,
                       AmpMailbox mailbox)
Adds a mailbox (optional operation).


removeMailbox

void removeMailbox(java.lang.String address,
                   AmpMailbox mailbox)
Removes a mailbox (optional operation).


close

void close()
Close the broker.