com.caucho.bam.manager

Class SimpleBamManager

java.lang.Object

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

Constructors

Constructor and Description
SimpleBamManager(Broker broker)
SimpleBamManager(ManagedBroker broker)

Method Summary

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