org.ow2.petals.jbi.messaging.registry
Class DistributedEndpointRegistryImpl

java.lang.Object
  org.ow2.petals.jbi.messaging.registry.AbstractEndpointRegistry
      org.ow2.petals.jbi.messaging.registry.BaseEndpointRegistry
          org.ow2.petals.jbi.messaging.registry.DistributedEndpointRegistryImpl

All Implemented Interfaces:

EndpointRegistry, EndpointRegistryMBean, RegistryManagement

public class DistributedEndpointRegistryImpl
extends BaseEndpointRegistry

The registry facade implementation based on the petals-registry-* project.

Author:

chamerling - eBM WebSourcing

Field Summary

protected ConfigurationService	configurationService Configuration service fractal component
protected java.util.Hashtable<java.lang.String,java.lang.Object>	listeners
protected ContainerConfiguration	localContainerConfiguration
protected TopologyService	localTopologyService

Fields inherited from class org.ow2.petals.jbi.messaging.registry.BaseEndpointRegistry

client, CONFIG, LISTENER_FRACTAL_PREFIX, registry

Fields inherited from class org.ow2.petals.jbi.messaging.registry.AbstractEndpointRegistry

log

Fields inherited from interface org.ow2.petals.jbi.messaging.registry.EndpointRegistryMBean

KEY_COMPONENT_NAME, KEY_CONTAINER_NAME, KEY_ENDPOINT_NAME, KEY_INTERFACE_NAMES, KEY_SERVICE_NAME, KEY_TYPE, TYPE_EXTERNAL, TYPE_INTERNAL, UNDEFINED

Constructor Summary

DistributedEndpointRegistryImpl()

Method Summary

protected void	createRegistryConfig(java.io.File f)
protected void	createRegistryTopology()
protected void	createTopologyUpdater()
java.util.List<RegistryListener>	getListeners() Get the list of registry listeners.
protected java.lang.String	getRootPath() Get the root path where the endpoints will be stored.
protected void	loadRegistry()
protected void	start()
protected void	stop()
void	synchronizeData() Synchronize the data from the registry newtork

Methods inherited from class org.ow2.petals.jbi.messaging.registry.BaseEndpointRegistry

activateEndpoint, deactivateEndpoint, deregisterConnection, deregisterConnection, deregisterExternalEndpoint, getDescription, getEndpoint, getEndpointDescriptorForEndpoint, getExternalEndpoints, getExternalEndpointsForInterface, getExternalEndpointsForService, getInterfacesForEndpoint, getInternalEndpoints, getInternalEndpointsForInterface, getInternalEndpointsForService, getKey, query, registerConnection, registerConnection, registerEndpoint, registerExternalEndpoint, removeAllLocalEndpoints

Methods inherited from class org.ow2.petals.jbi.messaging.registry.AbstractEndpointRegistry

getAllEndpoints, getAllExternalEndpoints, getAllInternalEndpoints, getEndpoints, interfaceQNameToString

Methods inherited from class java.lang.Object

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

Field Detail

configurationService

protected ConfigurationService configurationService

Configuration service fractal component

localTopologyService

protected TopologyService localTopologyService

listeners

protected java.util.Hashtable<java.lang.String,java.lang.Object> listeners

localContainerConfiguration

protected ContainerConfiguration localContainerConfiguration

Constructor Detail

DistributedEndpointRegistryImpl

public DistributedEndpointRegistryImpl()

Method Detail

start

protected void start()
              throws java.lang.Exception

Throws:

java.lang.Exception

loadRegistry

protected void loadRegistry()
                     throws org.ow2.petals.registry.api.exception.RegistryException,
                            org.ow2.petals.kernel.api.server.PetalsException

Throws:

RegistryException

org.ow2.petals.kernel.api.server.PetalsException

org.ow2.petals.registry.api.exception.RegistryException

createTopologyUpdater

protected void createTopologyUpdater()

Parameters:

updatePeriod -

createRegistryTopology

protected void createRegistryTopology()
                               throws org.ow2.petals.kernel.api.server.PetalsException

Throws:

org.ow2.petals.kernel.api.server.PetalsException

createRegistryConfig

protected void createRegistryConfig(java.io.File f)
                             throws org.ow2.petals.registry.api.exception.RegistryException

Parameters:

f -

localContainerConfiguration -

Throws:

RegistryException

org.ow2.petals.registry.api.exception.RegistryException

stop

protected void stop()
             throws java.lang.Exception

Throws:

java.lang.Exception

getRootPath

protected final java.lang.String getRootPath()

Description copied from class: BaseEndpointRegistry

Get the root path where the endpoints will be stored.

Specified by:

getRootPath in class BaseEndpointRegistry

Returns:

A path which must end with '/'

getListeners

public java.util.List<RegistryListener> getListeners()

Get the list of registry listeners. This can be used iin the implementation to do special things such as monitoring etc...

Returns:

synchronizeData

public void synchronizeData()
                     throws RegistryException

Synchronize the data from the registry newtork

Throws:

RegistryException