com.caucho.amp.broker

Interface AmpBroker

All Known Implementing Classes:

AbstractAmpBroker, HashMapAmpBroker

public interface AmpBroker

AmpRouter routes messages to mailboxes.

Method Summary

Modifier and Type	Method and Description
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.