jadex.bridge.service.search

Class MultiServiceRegistry

java.lang.Object

jadex.bridge.service.search.MultiServiceRegistry

All Implemented Interfaces:

IRegistryDataProvider, IServiceRegistry

public class MultiServiceRegistry
extends java.lang.Object
implements IServiceRegistry, IRegistryDataProvider

Service registry that holds copies of multiple other platform registries. Search methods operate transparently on all subregistries.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<ClassInfo,java.util.Set<ServiceQueryInfo<?>>>	queries The persistent service queries.
protected java.util.Map<IComponentIdentifier,IServiceRegistry>	registries The locally cloned registries of remote platforms.
protected RegistrySearchFunctionality	searchfunc The default search functionality.

Constructor Summary

Constructors

Constructor and Description
MultiServiceRegistry() Create a new registry.

Method Summary

Modifier and Type	Method and Description
void	addEventListener(IRegistryListener listener) Add an event listener.
void	addExcludedComponent(IComponentIdentifier cid) Add an excluded component.
<T> ISubscriptionIntermediateFuture<T>	addQuery(ServiceQuery<T> query) Add a service query to the registry.
IFuture<java.lang.Void>	addService(ClassInfo key, IService service) Add a service to the registry.
void	addSubregistry(IComponentIdentifier cid, IServiceRegistry registry) Add a new registry.
<T> java.util.Set<ServiceQueryInfo<T>>	getQueries(ClassInfo type) Get queries per type.
java.util.Map<ClassInfo,java.util.Set<IService>>	getServiceMap() Get the service map.
java.util.Iterator<IService>	getServices(ClassInfo type) Get services per type.
IServiceRegistry	getSubregistry(IComponentIdentifier cid) Get a subregistry.
boolean	isIncluded(IComponentIdentifier cid, IService ser) Test if a service is included.
protected void	registryAdded(IServiceRegistry registry) Called when a new registry was added.
void	removeEventListener(IRegistryListener listener) Remove an event listener.
IFuture<java.lang.Void>	removeExcludedComponent(IComponentIdentifier cid) Remove an excluded component.
void	removeQueries(IComponentIdentifier owner) Remove all service queries of a specific component from the registry.
<T> void	removeQuery(ServiceQuery<T> query) Remove a service query from the registry.
void	removeService(ClassInfo key, IService service) Remove a service from the registry.
void	removeSubregistry(IComponentIdentifier cid) Remove an existing registry.
<T> IFuture<T>	searchGlobalService(ClassInfo type, IComponentIdentifier cid, IAsyncFilter<T> filter) Search for services.
<T> ISubscriptionIntermediateFuture<T>	searchGlobalServices(ClassInfo type, IComponentIdentifier cid, IAsyncFilter<T> filter) Search for services.
<T> T	searchService(ClassInfo type, IComponentIdentifier cid, java.lang.String scope) Search for services.
<T> T	searchService(ClassInfo type, IComponentIdentifier cid, java.lang.String scope, boolean excluded) Search for services.
<T> IFuture<T>	searchService(ClassInfo type, IComponentIdentifier cid, java.lang.String scope, IAsyncFilter<T> filter) Search for service.
<T> T	searchService(ClassInfo type, IComponentIdentifier cid, java.lang.String scope, IFilter<T> filter) Search for service.
<T> java.util.Collection<T>	searchServices(ClassInfo type, IComponentIdentifier cid, java.lang.String scope) Search for services.
<T> ISubscriptionIntermediateFuture<T>	searchServices(ClassInfo type, IComponentIdentifier cid, java.lang.String scope, IAsyncFilter<T> filter) Search for services.
<T> java.util.Collection<T>	searchServices(ClassInfo type, IComponentIdentifier cid, java.lang.String scope, IFilter<T> filter) Search for service.
java.lang.String	toString() Get the string representation.

Methods inherited from class java.lang.Object

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

Field Detail

registries

protected java.util.Map<IComponentIdentifier,IServiceRegistry> registries

The locally cloned registries of remote platforms.

queries

protected java.util.Map<ClassInfo,java.util.Set<ServiceQueryInfo<?>>> queries

The persistent service queries.

searchfunc

protected RegistrySearchFunctionality searchfunc

The default search functionality.

Constructor Detail

MultiServiceRegistry

public MultiServiceRegistry()

Create a new registry.

Method Detail

getServiceMap

public java.util.Map<ClassInfo,java.util.Set<IService>> getServiceMap()

Get the service map.

Specified by:

getServiceMap in interface IServiceRegistry

Returns:

The full service map.

getServices

public java.util.Iterator<IService> getServices(ClassInfo type)

Get services per type.

Specified by:

getServices in interface IRegistryDataProvider

Specified by:

getServices in interface IServiceRegistry

Parameters:

type - The interface type. If type is null all services are returned.

Returns:

First matching service or null.

addService

public IFuture<java.lang.Void> addService(ClassInfo key,
                                          IService service)

Add a service to the registry.

Specified by:

addService in interface IServiceRegistry

Parameters:

sid - The service id.

removeService

public void removeService(ClassInfo key,
                          IService service)

Remove a service from the registry.

Specified by:

removeService in interface IServiceRegistry

Parameters:

sid - The service id.

addExcludedComponent

public void addExcludedComponent(IComponentIdentifier cid)

Add an excluded component.

Specified by:

addExcludedComponent in interface IServiceRegistry

Parameters:

The - component identifier.

removeExcludedComponent

public IFuture<java.lang.Void> removeExcludedComponent(IComponentIdentifier cid)

Remove an excluded component.

Specified by:

removeExcludedComponent in interface IServiceRegistry

Parameters:

The - component identifier.

isIncluded

public boolean isIncluded(IComponentIdentifier cid,
                          IService ser)

Test if a service is included.

Specified by:

isIncluded in interface IRegistryDataProvider

Specified by:

isIncluded in interface IServiceRegistry

Parameters:

ser - The service.

Returns:

True if is included.

addQuery

public <T> ISubscriptionIntermediateFuture<T> addQuery(ServiceQuery<T> query)

Add a service query to the registry.

Specified by:

addQuery in interface IServiceRegistry

Parameters:

query - ServiceQuery.

removeQuery

public <T> void removeQuery(ServiceQuery<T> query)

Remove a service query from the registry.

Specified by:

removeQuery in interface IServiceRegistry

Parameters:

query - ServiceQuery.

removeQueries

public void removeQueries(IComponentIdentifier owner)

Remove all service queries of a specific component from the registry.

Specified by:

removeQueries in interface IServiceRegistry

Parameters:

owner - The query owner.

getQueries

public <T> java.util.Set<ServiceQueryInfo<T>> getQueries(ClassInfo type)

Get queries per type.

Specified by:

getQueries in interface IRegistryDataProvider

Specified by:

getQueries in interface IServiceRegistry

Parameters:

type - The interface type. If type is null all services are returned.

Returns:

The queries.

searchService

public <T> T searchService(ClassInfo type,
                           IComponentIdentifier cid,
                           java.lang.String scope)

Search for services.

Specified by:

searchService in interface IServiceRegistry

searchService

public <T> T searchService(ClassInfo type,
                           IComponentIdentifier cid,
                           java.lang.String scope,
                           boolean excluded)

Search for services.

Specified by:

searchService in interface IServiceRegistry

searchServices

public <T> java.util.Collection<T> searchServices(ClassInfo type,
                                                  IComponentIdentifier cid,
                                                  java.lang.String scope)

Search for services.

Specified by:

searchServices in interface IServiceRegistry

searchService

public <T> T searchService(ClassInfo type,
                           IComponentIdentifier cid,
                           java.lang.String scope,
                           IFilter<T> filter)

Search for service.

Specified by:

searchService in interface IServiceRegistry

searchServices

public <T> java.util.Collection<T> searchServices(ClassInfo type,
                                                  IComponentIdentifier cid,
                                                  java.lang.String scope,
                                                  IFilter<T> filter)

Search for service.

Specified by:

searchServices in interface IServiceRegistry

searchService

public <T> IFuture<T> searchService(ClassInfo type,
                                    IComponentIdentifier cid,
                                    java.lang.String scope,
                                    IAsyncFilter<T> filter)

Search for service.

Specified by:

searchService in interface IServiceRegistry

searchServices

public <T> ISubscriptionIntermediateFuture<T> searchServices(ClassInfo type,
                                                             IComponentIdentifier cid,
                                                             java.lang.String scope,
                                                             IAsyncFilter<T> filter)

Search for services.

Specified by:

searchServices in interface IServiceRegistry

searchGlobalService

public <T> IFuture<T> searchGlobalService(ClassInfo type,
                                          IComponentIdentifier cid,
                                          IAsyncFilter<T> filter)

Search for services.

Specified by:

searchGlobalService in interface IServiceRegistry

searchGlobalServices

public <T> ISubscriptionIntermediateFuture<T> searchGlobalServices(ClassInfo type,
                                                                   IComponentIdentifier cid,
                                                                   IAsyncFilter<T> filter)

Search for services.

Specified by:

searchGlobalServices in interface IServiceRegistry

addEventListener

public void addEventListener(IRegistryListener listener)

Add an event listener.

Specified by:

addEventListener in interface IServiceRegistry

Parameters:

listener - The listener.

removeEventListener

public void removeEventListener(IRegistryListener listener)

Remove an event listener.

Specified by:

removeEventListener in interface IServiceRegistry

Parameters:

listener - The listener.

getSubregistry

public IServiceRegistry getSubregistry(IComponentIdentifier cid)

Get a subregistry.

Specified by:

getSubregistry in interface IServiceRegistry

Parameters:

cid - The platform id.

Returns:

The registry.

addSubregistry

public void addSubregistry(IComponentIdentifier cid,
                           IServiceRegistry registry)

Add a new registry.

Parameters:

registry - The registry.

removeSubregistry

public void removeSubregistry(IComponentIdentifier cid)

Remove an existing registry.

Specified by:

removeSubregistry in interface IServiceRegistry

Parameters:

cid - The component id to remove.

registryAdded

protected void registryAdded(IServiceRegistry registry)

Called when a new registry was added.

toString

public java.lang.String toString()

Get the string representation.

Overrides:

toString in class java.lang.Object