jadex.bridge.service.search

Class PlatformServiceRegistry

java.lang.Object

jadex.bridge.service.search.PlatformServiceRegistry

Direct Known Subclasses:

DistributedServiceRegistry

public class PlatformServiceRegistry
extends java.lang.Object

Local service registry. Is used by component service containers to add/remove service registrations. Search fetches services by types and excludes some according to the scope.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Set<IComponentIdentifier>	excluded The excluded components.
protected java.util.Map<ClassInfo,java.util.Set<IService>>	services The map of published services sorted by type.

Constructor Summary

Constructors

Constructor and Description
PlatformServiceRegistry()

Method Summary

Modifier and Type	Method and Description
void	addExcludedComponent(IComponentIdentifier cid) Add an excluded component.
void	addService(ClassInfo key, IService service) Add a service to the registry.
protected boolean	checkPublicationScope(IComponentIdentifier cid, IService ser) Check if service is ok with respect to publication scope.
protected boolean	checkSearchScope(IComponentIdentifier cid, IService ser, java.lang.String scope) Check if service is ok with respect to search scope of caller.
static java.lang.String	getApplicationName(IComponentIdentifier cid) Get the application name.
static java.lang.String	getDotName(IComponentIdentifier cid)
static PlatformServiceRegistry	getRegistry(IComponentIdentifier platform) Get the registry from a component.
static PlatformServiceRegistry	getRegistry(IInternalAccess ia) Get the registry from a component.
protected <T> T	getService(java.lang.Class<T> type) Get a service per type.
protected java.util.Set<IService>	getServices(java.lang.Class<?> type)
static java.lang.String	getSubcomponentName(IComponentIdentifier cid) Get the subcomponent name.
boolean	isIncluded(IComponentIdentifier cid, IService ser) Test if a service is included.
void	removeExcludedComponent(IComponentIdentifier cid) Remove an excluded component.
void	removeService(ClassInfo key, IService service) Remove a service from the registry.
<T> IFuture<T>	searchGlobalService(java.lang.Class<T> type, IComponentIdentifier cid, IAsyncFilter<T> filter) Search for services.
<T> ITerminableIntermediateFuture<T>	searchGlobalServices(java.lang.Class<T> type, IComponentIdentifier cid, IAsyncFilter<T> filter) Search for services.
protected <T> IFuture<T>	searchLoopService(IAsyncFilter<T> filter, java.util.Iterator<T> it, IComponentIdentifier cid, java.lang.String scope)
protected <T> ISubscriptionIntermediateFuture<T>	searchLoopServices(IAsyncFilter<T> filter, java.util.Iterator<T> it, IComponentIdentifier cid, java.lang.String scope)
protected <T> IFuture<T>	searchRemoteService(IComponentIdentifier caller, java.lang.Class<T> type, IAsyncFilter<T> filter) Search for services on remote platforms.
protected <T> ITerminableIntermediateFuture<T>	searchRemoteServices(IComponentIdentifier caller, java.lang.Class<T> type, IAsyncFilter<T> filter) Search for services on remote platforms.
<T> T	searchService(java.lang.Class<T> type, IComponentIdentifier cid, java.lang.String scope) Search for services.
<T> IFuture<T>	searchService(java.lang.Class<T> type, IComponentIdentifier cid, java.lang.String scope, IAsyncFilter<T> filter) Search for service.
<T> T	searchService(java.lang.Class<T> type, IComponentIdentifier cid, java.lang.String scope, IFilter<T> filter) Search for service.
<T> java.util.Collection<T>	searchServices(java.lang.Class<T> type, IComponentIdentifier cid, java.lang.String scope) Search for services.
<T> ISubscriptionIntermediateFuture<T>	searchServices(java.lang.Class<T> type, IComponentIdentifier cid, java.lang.String scope, IAsyncFilter<T> filter) Search for services.
<T> java.util.Collection<T>	searchServices(java.lang.Class<T> type, IComponentIdentifier cid, java.lang.String scope, IFilter<T> filter) Search for service.

Methods inherited from class java.lang.Object

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

Field Detail

services

protected java.util.Map<ClassInfo,java.util.Set<IService>> services

The map of published services sorted by type.

excluded

protected java.util.Set<IComponentIdentifier> excluded

The excluded components.

Constructor Detail

PlatformServiceRegistry

public PlatformServiceRegistry()

Method Detail

addExcludedComponent

public void addExcludedComponent(IComponentIdentifier cid)

Add an excluded component.

Parameters:

The - component identifier.

removeExcludedComponent

public void removeExcludedComponent(IComponentIdentifier cid)

Remove an excluded component.

Parameters:

The - component identifier.

isIncluded

public boolean isIncluded(IComponentIdentifier cid,
                          IService ser)

Test if a service is included.

Parameters:

ser - The service.

Returns:

True if is included.

addService

public void addService(ClassInfo key,
                       IService service)

Add a service to the registry.

Parameters:

sid - The service id.

removeService

public void removeService(ClassInfo key,
                          IService service)

Remove a service from the registry.

Parameters:

sid - The service id.

searchService

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

Search for services.

searchServices

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

Search for services.

searchService

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

Search for service.

searchServices

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

Search for service.

searchService

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

Search for service.

searchLoopService

protected <T> IFuture<T> searchLoopService(IAsyncFilter<T> filter,
                                           java.util.Iterator<T> it,
                                           IComponentIdentifier cid,
                                           java.lang.String scope)

Parameters:

filter -

it -

Returns:

searchServices

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

Search for services.

searchLoopServices

protected <T> ISubscriptionIntermediateFuture<T> searchLoopServices(IAsyncFilter<T> filter,
                                                                    java.util.Iterator<T> it,
                                                                    IComponentIdentifier cid,
                                                                    java.lang.String scope)

Parameters:

filter -

it -

Returns:

searchGlobalService

public <T> IFuture<T> searchGlobalService(java.lang.Class<T> type,
                                          IComponentIdentifier cid,
                                          IAsyncFilter<T> filter)

Search for services.

searchGlobalServices

public <T> ITerminableIntermediateFuture<T> searchGlobalServices(java.lang.Class<T> type,
                                                                 IComponentIdentifier cid,
                                                                 IAsyncFilter<T> filter)

Search for services.

checkSearchScope

protected boolean checkSearchScope(IComponentIdentifier cid,
                                   IService ser,
                                   java.lang.String scope)

Check if service is ok with respect to search scope of caller.

checkPublicationScope

protected boolean checkPublicationScope(IComponentIdentifier cid,
                                        IService ser)

Check if service is ok with respect to publication scope.

searchRemoteServices

protected <T> ITerminableIntermediateFuture<T> searchRemoteServices(IComponentIdentifier caller,
                                                                    java.lang.Class<T> type,
                                                                    IAsyncFilter<T> filter)

Search for services on remote platforms.

Parameters:

caller - The component that started the search.

type - The type.

filter - The filter.

searchRemoteService

protected <T> IFuture<T> searchRemoteService(IComponentIdentifier caller,
                                             java.lang.Class<T> type,
                                             IAsyncFilter<T> filter)

Search for services on remote platforms.

Parameters:

type - The type.

scope - The scope.

getService

protected <T> T getService(java.lang.Class<T> type)

Get a service per type.

Parameters:

type - The interface type.

Returns:

First matching service or null.

getServices

protected java.util.Set<IService> getServices(java.lang.Class<?> type)

getApplicationName

public static java.lang.String getApplicationName(IComponentIdentifier cid)

Get the application name. Equals the local component name in case it is a child of the platform. broadcast@awa.plat1 -> awa

Returns:

The application name.

getSubcomponentName

public static java.lang.String getSubcomponentName(IComponentIdentifier cid)

Get the subcomponent name.

Parameters:

cid - The component id.

Returns:

The subcomponent name.

getDotName

public static java.lang.String getDotName(IComponentIdentifier cid)

getRegistry

public static PlatformServiceRegistry getRegistry(IComponentIdentifier platform)

Get the registry from a component.

getRegistry

public static PlatformServiceRegistry getRegistry(IInternalAccess ia)

Get the registry from a component.