com.metamatrix.platform.registry
Class ClusteredRegistryState

java.lang.Object
  com.metamatrix.platform.registry.ClusteredRegistryState

All Implemented Interfaces:

CacheListener

public class ClusteredRegistryState
extends java.lang.Object
implements CacheListener

Constructor Summary

ClusteredRegistryState(CacheFactory cacheFactory)

Method Summary

protected void	addHost(HostControllerRegistryBinding binding)
void	addListener(RegistryListener obj) Add a listener for the registry node
protected void	addProcess(java.lang.String hostName, java.lang.String processName, ProcessRegistryBinding vmBinding)
protected void	addServiceBinding(java.lang.String hostName, java.lang.String processName, ServiceRegistryBinding binding)
void	cacheChanged()
java.util.List<ServiceRegistryBinding>	getActiveServiceBindings(java.lang.String hostName, java.lang.String processName, java.lang.String serviceType)
HostControllerRegistryBinding	getHost(java.lang.String hostName)
java.util.List<HostControllerRegistryBinding>	getHosts() Returns the all the host that have been known to registry.
ProcessRegistryBinding	getProcessBinding(java.lang.String hostName, java.lang.String processName)
ServiceRegistryBinding	getServiceBinding(java.lang.String hostName, java.lang.String processName, ServiceID serviceId)
java.util.List<ServiceRegistryBinding>	getServiceBindings(java.lang.String serviceType)
java.util.List<ServiceRegistryBinding>	getServiceBindings(java.lang.String hostName, java.lang.String processName)
java.util.List<ServiceRegistryBinding>	getServiceBindings(java.lang.String hostName, java.lang.String processName, java.lang.String serviceType)
java.util.List<ProcessRegistryBinding>	getVMs(java.lang.String hostName) Gets all the VMs for a given Host.
protected void	removeHost(java.lang.String hostName)
protected void	removeProcess(java.lang.String hostName, java.lang.String processName)
protected void	removeServiceBinding(java.lang.String hostName, java.lang.String processName, ServiceID serviceId)
void	shutdown()
protected void	updateProcess(java.lang.String hostName, java.lang.String processName, ProcessRegistryBinding binding)
protected void	updateServiceBinding(java.lang.String hostName, java.lang.String processName, ServiceRegistryBinding binding)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusteredRegistryState

public ClusteredRegistryState(CacheFactory cacheFactory)

Method Detail

addHost

protected void addHost(HostControllerRegistryBinding binding)

removeHost

protected void removeHost(java.lang.String hostName)

addProcess

protected void addProcess(java.lang.String hostName,
                          java.lang.String processName,
                          ProcessRegistryBinding vmBinding)
                   throws com.metamatrix.platform.registry.ClusteredRegistryState.CacheNodeNotFoundException

Throws:

com.metamatrix.platform.registry.ClusteredRegistryState.CacheNodeNotFoundException

updateProcess

protected void updateProcess(java.lang.String hostName,
                             java.lang.String processName,
                             ProcessRegistryBinding binding)
                      throws ResourceNotBoundException,
                             com.metamatrix.platform.registry.ClusteredRegistryState.CacheNodeNotFoundException

Throws:

ResourceNotBoundException

com.metamatrix.platform.registry.ClusteredRegistryState.CacheNodeNotFoundException

removeProcess

protected void removeProcess(java.lang.String hostName,
                             java.lang.String processName)

getHosts

public java.util.List<HostControllerRegistryBinding> getHosts()

Returns the all the host that have been known to registry.

Returns:

getHost

public HostControllerRegistryBinding getHost(java.lang.String hostName)

getVMs

public java.util.List<ProcessRegistryBinding> getVMs(java.lang.String hostName)

Gets all the VMs for a given Host. If 'null' is passed in for the host name it will return all the VMs in the cluster.

Parameters:

hostName -

Returns:

getProcessBinding

public ProcessRegistryBinding getProcessBinding(java.lang.String hostName,
                                                java.lang.String processName)
                                         throws ResourceNotBoundException

Throws:

ResourceNotBoundException

addServiceBinding

protected void addServiceBinding(java.lang.String hostName,
                                 java.lang.String processName,
                                 ServiceRegistryBinding binding)
                          throws ResourceAlreadyBoundException,
                                 com.metamatrix.platform.registry.ClusteredRegistryState.CacheNodeNotFoundException

Throws:

ResourceAlreadyBoundException

com.metamatrix.platform.registry.ClusteredRegistryState.CacheNodeNotFoundException

updateServiceBinding

protected void updateServiceBinding(java.lang.String hostName,
                                    java.lang.String processName,
                                    ServiceRegistryBinding binding)
                             throws ResourceNotBoundException,
                                    com.metamatrix.platform.registry.ClusteredRegistryState.CacheNodeNotFoundException

Throws:

ResourceNotBoundException

com.metamatrix.platform.registry.ClusteredRegistryState.CacheNodeNotFoundException

getServiceBinding

public ServiceRegistryBinding getServiceBinding(java.lang.String hostName,
                                                java.lang.String processName,
                                                ServiceID serviceId)
                                         throws ResourceNotBoundException

Throws:

ResourceNotBoundException

getActiveServiceBindings

public java.util.List<ServiceRegistryBinding> getActiveServiceBindings(java.lang.String hostName,
                                                                       java.lang.String processName,
                                                                       java.lang.String serviceType)

getServiceBindings

public java.util.List<ServiceRegistryBinding> getServiceBindings(java.lang.String serviceType)

getServiceBindings

public java.util.List<ServiceRegistryBinding> getServiceBindings(java.lang.String hostName,
                                                                 java.lang.String processName,
                                                                 java.lang.String serviceType)

getServiceBindings

public java.util.List<ServiceRegistryBinding> getServiceBindings(java.lang.String hostName,
                                                                 java.lang.String processName)

removeServiceBinding

protected void removeServiceBinding(java.lang.String hostName,
                                    java.lang.String processName,
                                    ServiceID serviceId)

addListener

public void addListener(RegistryListener obj)

Add a listener for the registry node

Parameters:

obj -

cacheChanged

public void cacheChanged()

Specified by:

cacheChanged in interface CacheListener

shutdown

public void shutdown()