jadex.bridge.service.search

Class RegistrySearchFunctionality

java.lang.Object

jadex.bridge.service.search.RegistrySearchFunctionality

public class RegistrySearchFunctionality
extends java.lang.Object

This class contains default search functionalities for services. It also contains search based implementation of the global search.

Field Summary

Fields

Modifier and Type	Field and Description
protected IRegistryDataProvider	provider Interface to the data of the registry.

Constructor Summary

Constructors

Constructor and Description
RegistrySearchFunctionality(IRegistryDataProvider provider) Create a new search func.

Method Summary

Modifier and Type	Method and Description
protected <T> ISubscriptionIntermediateFuture<T>	checkAsyncFilters(IAsyncFilter<T> filter, java.util.Iterator<T> it) Check the async filter.
protected boolean	checkPublicationScope(IComponentIdentifier cid, IService ser) Check if service is ok with respect to publication scope.
protected IFuture<java.lang.Void>	checkQueries(IService ser) Check the persistent queries for a new service.
protected IFuture<java.lang.Void>	checkQueriesLoop(java.util.Iterator<ServiceQueryInfo<?>> it, IService service) Check the persistent queries against a new service.
protected IFuture<java.lang.Boolean>	checkQuery(ServiceQueryInfo<?> queryinfo, IService service) Check a persistent query with one service.
protected <T> java.util.Collection<T>	checkScope(java.util.Iterator<T> it, IComponentIdentifier cid, java.lang.String scope, boolean oneresult) Check the services according the the scope.
protected boolean	checkSearchScope(IComponentIdentifier cid, IService ser, java.lang.String scope, boolean excluded) 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) Get the name without @ replaced by dot.
protected <T> java.util.Set<ServiceQueryInfo<T>>	getQueries(ClassInfo type) Get queries per type.
protected java.util.Iterator<IService>	getServices(ClassInfo type) Get services per type.
static java.lang.String	getSubcomponentName(IComponentIdentifier cid) Get the subcomponent name.
<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.

Methods inherited from class java.lang.Object

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

Field Detail

provider

protected IRegistryDataProvider provider

Interface to the data of the registry.

Constructor Detail

RegistrySearchFunctionality

public RegistrySearchFunctionality(IRegistryDataProvider provider)

Create a new search func.

Method Detail

getServices

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

Get services per type.

Parameters:

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

Returns:

First matching service or null.

getQueries

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

Get queries per type.

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.

searchService

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

Search for services.

searchServices

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

Search for services.

searchService

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

Search for service.

searchServices

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

Search for service.

searchService

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

Search for service.

searchServices

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

Search for services.

checkScope

protected <T> java.util.Collection<T> checkScope(java.util.Iterator<T> it,
                                                 IComponentIdentifier cid,
                                                 java.lang.String scope,
                                                 boolean oneresult)

Check the services according the the scope.

Parameters:

it - The services.

cid - The component id.

scope - The scope.

Returns:

The services that fit to the scope.

checkAsyncFilters

protected <T> ISubscriptionIntermediateFuture<T> checkAsyncFilters(IAsyncFilter<T> filter,
                                                                   java.util.Iterator<T> it)

Check the async filter.

Parameters:

filter - The filter

it - The services.

Returns:

The services that pass the filter.

checkQueries

protected IFuture<java.lang.Void> checkQueries(IService ser)

Check the persistent queries for a new service.

Parameters:

ser - The service.

checkQueriesLoop

protected IFuture<java.lang.Void> checkQueriesLoop(java.util.Iterator<ServiceQueryInfo<?>> it,
                                                   IService service)

Check the persistent queries against a new service.

Parameters:

it - The queries.

service - the service.

checkQuery

protected IFuture<java.lang.Boolean> checkQuery(ServiceQueryInfo<?> queryinfo,
                                                IService service)

Check a persistent query with one service.

Parameters:

queryinfo - The query.

service - The service.

Returns:

True, if services matches to query.

checkSearchScope

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

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.

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)

Get the name without @ replaced by dot.