orca.shirako.registry
Class PeerRegistry

java.lang.Object
  orca.shirako.registry.PeerRegistry

All Implemented Interfaces:

IInitialize

public class PeerRegistry
extends java.lang.Object
implements IInitialize

Field Summary

protected java.util.Hashtable<java.lang.String,IBrokerProxy>	brokers A hash table of proxies to brokers.
protected MapSet	cache Cache of objects per actor name
protected IBrokerProxy	defaultBroker
protected LoggingTool	logger
protected IShirakoPlugin	spi

Constructor Summary

PeerRegistry()

Method Summary

void	actorAdded()
void	addBroker(IBrokerProxy broker)
IBrokerProxy	getBroker(java.lang.String name)
IBrokerProxy[]	getBrokers()
IBrokerProxy	getDefaultBroker()
void	initialize() Initializes the object.
protected void	loadFromDB()
void	removeBroker(IBrokerProxy broker)
void	setSlicesPlugin(IShirakoPlugin spi)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

brokers

protected java.util.Hashtable<java.lang.String,IBrokerProxy> brokers

A hash table of proxies to brokers. Persisted to the data store.

defaultBroker

protected IBrokerProxy defaultBroker

cache

protected MapSet cache

Cache of objects per actor name

spi

protected IShirakoPlugin spi

logger

protected LoggingTool logger

Constructor Detail

PeerRegistry

public PeerRegistry()

Method Detail

initialize

public void initialize()
                throws java.lang.Exception

Description copied from interface: IInitialize

Initializes the object.

Specified by:

initialize in interface IInitialize

Throws:

java.lang.Exception

actorAdded

public void actorAdded()
                throws java.lang.Exception

Throws:

java.lang.Exception

loadFromDB

protected void loadFromDB()
                   throws java.lang.Exception

Throws:

java.lang.Exception

getBrokers

public IBrokerProxy[] getBrokers()

getBroker

public IBrokerProxy getBroker(java.lang.String name)

getDefaultBroker

public IBrokerProxy getDefaultBroker()

addBroker

public void addBroker(IBrokerProxy broker)

removeBroker

public void removeBroker(IBrokerProxy broker)
                  throws java.lang.Exception

Throws:

java.lang.Exception

setSlicesPlugin

public void setSlicesPlugin(IShirakoPlugin spi)