com.caucho.bam.manager
Class SimpleBamManager

java.lang.Object
  extended by com.caucho.bam.manager.SimpleBamManager
All Implemented Interfaces:
BamManager

public class SimpleBamManager
extends java.lang.Object
implements BamManager

Broker is the hub which routes messages to actors.


Constructor Summary
SimpleBamManager(Broker broker)
           
SimpleBamManager(ManagedBroker broker)
           
 
Method Summary
 void addActor(java.lang.String address, ManagedActor actor)
          Adds an actor and creates a default mailbox
 void addActorBean(java.lang.String address, java.lang.Object bean)
          Creates a skeleton actor.
 void addMailbox(java.lang.String address, Mailbox mailbox)
          Adds a mailbox.
 BamActorRef createActorRef(java.lang.String to)
           
 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)
           
 ActorSender createClient(java.lang.String address)
           
 ActorSender createClient(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)
           
<T> T
createProxy(java.lang.Class<T> api, BamActorRef to, ActorSender sender)
           
<T> T
createProxy(java.lang.Class<T> api, java.lang.String to)
           
<T> T
createProxy(java.lang.Class<T> api, java.lang.String to, ActorSender sender)
           
 Mailbox createService(java.lang.String address, java.lang.Object bean)
          Creates a skeleton actor.
 ManagedBroker getBroker()
          Returns the managed broker
 long getTimeout()
           
 void removeMailbox(Mailbox mailbox)
          Removes a mailbox.
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

SimpleBamManager

public SimpleBamManager(Broker broker)

SimpleBamManager

public SimpleBamManager(ManagedBroker broker)
Method Detail

getBroker

public ManagedBroker getBroker()
Description copied from interface: BamManager
Returns the managed broker

Specified by:
getBroker in interface BamManager

getTimeout

public long getTimeout()

addMailbox

public void addMailbox(java.lang.String address,
                       Mailbox mailbox)
Adds a mailbox.

Specified by:
addMailbox in interface BamManager

removeMailbox

public void removeMailbox(Mailbox mailbox)
Removes a mailbox.

Specified by:
removeMailbox in interface BamManager

addActor

public void addActor(java.lang.String address,
                     ManagedActor actor)
Description copied from interface: BamManager
Adds an actor and creates a default mailbox

Specified by:
addActor in interface BamManager

addActorBean

public void addActorBean(java.lang.String address,
                         java.lang.Object bean)
Creates a skeleton actor.


createService

public Mailbox createService(java.lang.String address,
                             java.lang.Object bean)
Creates a skeleton actor.

Specified by:
createService in interface BamManager
Returns:

createAgent

public Agent createAgent(MessageStream actorStream)
Creates an agent

Specified by:
createAgent in interface BamManager

createAgent

public Agent createAgent(MessageStream actorStream,
                         MailboxType mailboxType)
Creates an agent

Specified by:
createAgent in interface BamManager

createMailbox

protected Mailbox createMailbox(MessageStream actorStream,
                                MailboxType mailboxType)

createMailbox

protected Mailbox createMailbox(java.lang.String address,
                                MessageStream actorStream,
                                MailboxType mailboxType)

createClient

public Mailbox createClient(Mailbox next,
                            java.lang.String uid,
                            java.lang.String resource)
Specified by:
createClient in interface BamManager

createClient

public ActorSender createClient(java.lang.String uid,
                                java.lang.String resource)
Specified by:
createClient in interface BamManager

createActorRef

public BamActorRef createActorRef(java.lang.String to)
Specified by:
createActorRef in interface BamManager

createProxy

public <T> T createProxy(java.lang.Class<T> api,
                         java.lang.String to)
Specified by:
createProxy in interface BamManager

createProxy

public <T> T createProxy(java.lang.Class<T> api,
                         BamActorRef to,
                         ActorSender sender)
Specified by:
createProxy in interface BamManager

createProxy

public <T> T createProxy(java.lang.Class<T> api,
                         java.lang.String to,
                         ActorSender sender)
Specified by:
createProxy in interface BamManager

createClient

public ActorSender createClient(java.lang.String address)

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object