jadex.bridge.service.search

Class SServiceProvider

java.lang.Object

jadex.bridge.service.search.SServiceProvider

public class SServiceProvider
extends java.lang.Object

Static helper class for searching services.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SServiceProvider.IntermediateProxyResultListener<T>
static class	SServiceProvider.ProxyResultListener<T>

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.Map	methodreferences The reference method cache (method -> boolean[] (is reference)).

Constructor Summary

Constructors

Constructor and Description
SServiceProvider()

Method Summary

Modifier and Type	Method and Description
protected static void	checkComponent(IInternalAccess component) Check access not null and throw exception otherwise.
protected static void	checkThreadAccess(IInternalAccess component, boolean proxy) Check thread access and throw exception if is not component thread.
protected static <T> java.util.Collection<T>	createRequiredProxies(IInternalAccess component, java.util.Collection<T> sers, java.lang.Class<?> type) Create a required service proxies.
protected static <T> T	createRequiredProxy(IInternalAccess component, T ser, java.lang.Class<?> type) Create a required service proxy.
protected static IFuture<java.lang.Void>	ensureThreadAccess(IInternalAccess component, boolean proxy) Check access not null and throw exception otherwise.
static <T> IFuture<T>	getDeclaredService(IExternalAccess provider, java.lang.Class<T> type) Get all declared services of the given provider.
static <T> IFuture<T>	getDeclaredService(IInternalAccess component, java.lang.Class<T> type) Get all declared services of the given provider.
static <T> IFuture<T>	getDeclaredService(IInternalAccess component, java.lang.Class<T> type, boolean proxy) Get all declared services of the given provider.
static IIntermediateFuture<IService>	getDeclaredServices(IExternalAccess provider) Get all declared services of the given provider.
static IIntermediateFuture<IService>	getDeclaredServices(IInternalAccess component) Get all declared services of the given provider.
static IIntermediateFuture<IService>	getDeclaredServices(IInternalAccess component, boolean proxy) Get all declared services of the given provider.
static boolean[]	getLocalReferenceInfo(java.lang.reflect.Method method, boolean refdef) Get the copy info for method parameters.
static <T> T	getLocalService(IComponentIdentifier component, java.lang.Class<T> type) Get one service of a type.
static <T> T	getLocalService(IComponentIdentifier component, java.lang.Class<T> type, java.lang.String scope) Get one service of a type.
static <T> T	getLocalService(IComponentIdentifier component, java.lang.Class<T> type, java.lang.String scope, IFilter<T> filter) Get one service of a type.
static <T> T	getLocalService(IInternalAccess component, java.lang.Class<T> type) Get one service of a type.
static <T> T	getLocalService(IInternalAccess component, java.lang.Class<T> type, boolean proxy) Get one service of a type.
static <T> T	getLocalService(IInternalAccess component, java.lang.Class<T> type, IComponentIdentifier target) Get one service of a type.
static <T> T	getLocalService(IInternalAccess component, java.lang.Class<T> type, IComponentIdentifier target, boolean proxy) Get one service of a type.
static <T> T	getLocalService(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope) Get one service of a type.
static <T> T	getLocalService(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, boolean proxy) Get one service of a type.
static <T> T	getLocalService(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IFilter<T> filter) Get one service of a type.
static <T> T	getLocalService(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IFilter<T> filter, boolean proxy) Get one service of a type.
static <T> T	getLocalService0(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IFilter<T> filter, boolean proxy) Get one service of a type.
static <T> java.util.Collection<T>	getLocalServices(IInternalAccess component, java.lang.Class<T> type) Get one service of a type.
static <T> java.util.Collection<T>	getLocalServices(IInternalAccess component, java.lang.Class<T> type, boolean proxy) Get one service of a type.
static <T> java.util.Collection<T>	getLocalServices(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope) Get one service of a type.
static <T> java.util.Collection<T>	getLocalServices(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, boolean proxy) Get one service of a type.
static <T> java.util.Collection<T>	getLocalServices(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IFilter<T> filter) Get one service of a type.
static <T> java.util.Collection<T>	getLocalServices(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IFilter<T> filter, boolean proxy) Get one service of a type.
static boolean[]	getReferenceInfo(java.lang.reflect.Method method, boolean refdef, boolean local) Get the copy info for method parameters.
static boolean[]	getRemoteReferenceInfo(java.lang.reflect.Method method, boolean refdef) Get the copy info for method parameters.
static <T> IFuture<T>	getService(IExternalAccess provider, java.lang.Class<T> type) Get one service of a type.
static <T> IFuture<T>	getService(IExternalAccess provider, java.lang.Class<T> type, java.lang.String scope) Get one service of a type.
static <T> IFuture<T>	getService(IExternalAccess provider, java.lang.Class<T> type, java.lang.String scope, IAsyncFilter<T> filter) Get one service of a type.
static <T> IFuture<T>	getService(IExternalAccess provider, IComponentIdentifier cid, java.lang.Class<T> type) Get a service from a specific component.
static <T> IFuture<T>	getService(IExternalAccess provider, IServiceIdentifier sid) Get one service with id.
static <T> IFuture<T>	getService(IInternalAccess component, java.lang.Class<T> type) Get one service of a type.
static <T> IFuture<T>	getService(IInternalAccess component, java.lang.Class<T> type, boolean proxy) Get one service of a type.
static <T> IFuture<T>	getService(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope) Get one service of a type.
static <T> IFuture<T>	getService(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, boolean proxy) Get one service of a type.
static <T> IFuture<T>	getService(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IAsyncFilter<T> filter) Get one service of a type.
static <T> IFuture<T>	getService(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IAsyncFilter<T> filter, boolean proxy) Get one service of a type.
static <T> IFuture<T>	getService(IInternalAccess component, IComponentIdentifier cid, java.lang.Class<T> type) Get a service from a specific component.
static <T> IFuture<T>	getService(IInternalAccess component, IComponentIdentifier cid, java.lang.Class<T> type, boolean proxy) Get a service from a specific component.
static <T> IFuture<T>	getService(IInternalAccess component, IServiceIdentifier sid) Get one service with id.
static <T> IFuture<T>	getService(IInternalAccess component, IServiceIdentifier sid, boolean proxy) Get one service with id.
static <T> ITerminableIntermediateFuture<T>	getServices(IExternalAccess provider, java.lang.Class<T> type) Get all services of a type.
static <T> ITerminableIntermediateFuture<T>	getServices(IExternalAccess provider, java.lang.Class<T> type, java.lang.String scope) Get all services of a type.
static <T> ITerminableIntermediateFuture<T>	getServices(IExternalAccess provider, java.lang.Class<T> type, java.lang.String scope, IAsyncFilter<T> filter) Get all services of a type.
static <T> ITerminableIntermediateFuture<T>	getServices(IInternalAccess component, java.lang.Class<T> type) Get all services of a type.
static <T> ITerminableIntermediateFuture<T>	getServices(IInternalAccess component, java.lang.Class<T> type, boolean proxy) Get all services of a type.
static <T> ITerminableIntermediateFuture<T>	getServices(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope) Get all services of a type.
static <T> ITerminableIntermediateFuture<T>	getServices(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, boolean proxy) Get all services of a type.
static <T> ITerminableIntermediateFuture<T>	getServices(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IAsyncFilter<T> filter) Get all services of a type.
static <T> ITerminableIntermediateFuture<T>	getServices(IInternalAccess component, java.lang.Class<T> type, java.lang.String scope, IAsyncFilter<T> filter, boolean proxy) Get all services of a type.
static boolean	isReturnValueLocalReference(java.lang.reflect.Method method, boolean refdef) Test if return value is local reference.
static boolean	isReturnValueRemoteReference(java.lang.reflect.Method method, boolean refdef) Get the copy info for method parameters.
static <S> ITerminableIntermediateFuture<S>	rankServices(ITerminableIntermediateFuture<S> searchfut, IServiceRanker<S> ranker, IRankingSearchTerminationDecider<S> decider) Rank the services of a search with a specific ranker.
static <S> ITerminableIntermediateFuture<Tuple2<S,java.lang.Double>>	rankServicesWithScores(ITerminableIntermediateFuture<S> searchfut, IServiceRanker<S> ranker, IRankingSearchTerminationDecider<S> decider) Rank the services of a search with a specific ranker and emit the scores.

Methods inherited from class java.lang.Object

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

Field Detail

methodreferences

public static final java.util.Map methodreferences

The reference method cache (method -> boolean[] (is reference)).

Constructor Detail

SServiceProvider

public SServiceProvider()

Method Detail

getLocalService

public static <T> T getLocalService(IComponentIdentifier component,
                                    java.lang.Class<T> type)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IComponentIdentifier component,
                                    java.lang.Class<T> type,
                                    java.lang.String scope)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IComponentIdentifier component,
                                    java.lang.Class<T> type,
                                    java.lang.String scope,
                                    IFilter<T> filter)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IInternalAccess component,
                                    java.lang.Class<T> type)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IInternalAccess component,
                                    java.lang.Class<T> type,
                                    java.lang.String scope)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IInternalAccess component,
                                    java.lang.Class<T> type,
                                    java.lang.String scope,
                                    IFilter<T> filter)

Get one service of a type. (Returns required service proxy).

Parameters:

component - The internal access.

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IInternalAccess component,
                                    java.lang.Class<T> type,
                                    IComponentIdentifier target)

Get one service of a type. (Returns required service proxy).

Parameters:

component - The internal access.

type - The class.

Returns:

The corresponding service.

getLocalServices

public static <T> java.util.Collection<T> getLocalServices(IInternalAccess component,
                                                           java.lang.Class<T> type)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalServices

public static <T> java.util.Collection<T> getLocalServices(IInternalAccess component,
                                                           java.lang.Class<T> type,
                                                           java.lang.String scope)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalServices

public static <T> java.util.Collection<T> getLocalServices(IInternalAccess component,
                                                           java.lang.Class<T> type,
                                                           java.lang.String scope,
                                                           IFilter<T> filter)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IInternalAccess component,
                                    java.lang.Class<T> type,
                                    boolean proxy)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IInternalAccess component,
                                    java.lang.Class<T> type,
                                    java.lang.String scope,
                                    boolean proxy)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IInternalAccess component,
                                    java.lang.Class<T> type,
                                    java.lang.String scope,
                                    IFilter<T> filter,
                                    boolean proxy)

Get one service of a type. (Returns required service proxy).

Parameters:

component - The internal access.

type - The class.

Returns:

The corresponding service.

getLocalService0

public static <T> T getLocalService0(IInternalAccess component,
                                     java.lang.Class<T> type,
                                     java.lang.String scope,
                                     IFilter<T> filter,
                                     boolean proxy)

Get one service of a type. (Returns required service proxy).

Parameters:

component - The internal access.

type - The class.

Returns:

The corresponding service.

getLocalService

public static <T> T getLocalService(IInternalAccess component,
                                    java.lang.Class<T> type,
                                    IComponentIdentifier target,
                                    boolean proxy)

Get one service of a type. (Returns required service proxy).

Parameters:

component - The internal access.

type - The class.

Returns:

The corresponding service.

getLocalServices

public static <T> java.util.Collection<T> getLocalServices(IInternalAccess component,
                                                           java.lang.Class<T> type,
                                                           boolean proxy)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalServices

public static <T> java.util.Collection<T> getLocalServices(IInternalAccess component,
                                                           java.lang.Class<T> type,
                                                           java.lang.String scope,
                                                           boolean proxy)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getLocalServices

public static <T> java.util.Collection<T> getLocalServices(IInternalAccess component,
                                                           java.lang.Class<T> type,
                                                           java.lang.String scope,
                                                           IFilter<T> filter,
                                                           boolean proxy)

Get one service of a type. (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        java.lang.Class<T> type)

Get one service of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        java.lang.Class<T> type,
                                        java.lang.String scope)

Get one service of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        java.lang.Class<T> type,
                                        java.lang.String scope,
                                        IAsyncFilter<T> filter)

Get one service of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        IServiceIdentifier sid)

Get one service with id. // * (Returns required service proxy).

Parameters:

clazz - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        IComponentIdentifier cid,
                                        java.lang.Class<T> type)

Get a service from a specific component. // * (Returns required service proxy).

Parameters:

component - The component.

cid - The target component identifier.

type - The service type.

Returns:

The corresponding service.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IInternalAccess component,
                                                               java.lang.Class<T> type)

Get all services of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding services.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IInternalAccess component,
                                                               java.lang.Class<T> type,
                                                               java.lang.String scope)

Get all services of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding services.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IInternalAccess component,
                                                               java.lang.Class<T> type,
                                                               java.lang.String scope,
                                                               IAsyncFilter<T> filter)

Get all services of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding services.

getDeclaredService

public static <T> IFuture<T> getDeclaredService(IInternalAccess component,
                                                java.lang.Class<T> type)

Get all declared services of the given provider. // * (Returns required service proxy).

Returns:

The corresponding services.

getDeclaredServices

public static IIntermediateFuture<IService> getDeclaredServices(IInternalAccess component)

Get all declared services of the given provider. // * (Returns required service proxy).

Returns:

The corresponding services.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        java.lang.Class<T> type,
                                        boolean proxy)

Get one service of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        java.lang.Class<T> type,
                                        java.lang.String scope,
                                        boolean proxy)

Get one service of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        java.lang.Class<T> type,
                                        java.lang.String scope,
                                        IAsyncFilter<T> filter,
                                        boolean proxy)

Get one service of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        IServiceIdentifier sid,
                                        boolean proxy)

Get one service with id. // * (Returns required service proxy).

Parameters:

clazz - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IInternalAccess component,
                                        IComponentIdentifier cid,
                                        java.lang.Class<T> type,
                                        boolean proxy)

Get a service from a specific component. // * (Returns required service proxy).

Parameters:

component - The component.

cid - The target component identifier.

type - The service type.

Returns:

The corresponding service.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IInternalAccess component,
                                                               java.lang.Class<T> type,
                                                               boolean proxy)

Get all services of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding services.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IInternalAccess component,
                                                               java.lang.Class<T> type,
                                                               java.lang.String scope,
                                                               boolean proxy)

Get all services of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding services.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IInternalAccess component,
                                                               java.lang.Class<T> type,
                                                               java.lang.String scope,
                                                               IAsyncFilter<T> filter,
                                                               boolean proxy)

Get all services of a type. // * (Returns required service proxy).

Parameters:

type - The class.

Returns:

The corresponding services.

getDeclaredService

public static <T> IFuture<T> getDeclaredService(IInternalAccess component,
                                                java.lang.Class<T> type,
                                                boolean proxy)

Get all declared services of the given provider. // * (Returns required service proxy).

Returns:

The corresponding services.

getDeclaredServices

public static IIntermediateFuture<IService> getDeclaredServices(IInternalAccess component,
                                                                boolean proxy)

Get all declared services of the given provider. // * (Returns required service proxy).

Returns:

The corresponding services.

getService

public static <T> IFuture<T> getService(IExternalAccess provider,
                                        java.lang.Class<T> type)

Get one service of a type.

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IExternalAccess provider,
                                        java.lang.Class<T> type,
                                        java.lang.String scope)

Get one service of a type.

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IExternalAccess provider,
                                        java.lang.Class<T> type,
                                        java.lang.String scope,
                                        IAsyncFilter<T> filter)

Get one service of a type.

Parameters:

type - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IExternalAccess provider,
                                        IServiceIdentifier sid)

Get one service with id.

Parameters:

clazz - The class.

Returns:

The corresponding service.

getService

public static <T> IFuture<T> getService(IExternalAccess provider,
                                        IComponentIdentifier cid,
                                        java.lang.Class<T> type)

Get a service from a specific component.

Parameters:

provider - A service provider.

cid - The target component identifier.

type - The service type.

Returns:

The corresponding service.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IExternalAccess provider,
                                                               java.lang.Class<T> type)

Get all services of a type.

Parameters:

type - The class.

Returns:

The corresponding services.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IExternalAccess provider,
                                                               java.lang.Class<T> type,
                                                               java.lang.String scope)

Get all services of a type.

Parameters:

type - The class.

Returns:

The corresponding services.

getServices

public static <T> ITerminableIntermediateFuture<T> getServices(IExternalAccess provider,
                                                               java.lang.Class<T> type,
                                                               java.lang.String scope,
                                                               IAsyncFilter<T> filter)

Get all services of a type.

Parameters:

type - The class.

Returns:

The corresponding services.

getDeclaredService

public static <T> IFuture<T> getDeclaredService(IExternalAccess provider,
                                                java.lang.Class<T> type)

Get all declared services of the given provider.

Returns:

The corresponding services.

getDeclaredServices

public static IIntermediateFuture<IService> getDeclaredServices(IExternalAccess provider)

Get all declared services of the given provider.

Returns:

The corresponding services.

rankServices

public static <S> ITerminableIntermediateFuture<S> rankServices(ITerminableIntermediateFuture<S> searchfut,
                                                                IServiceRanker<S> ranker,
                                                                IRankingSearchTerminationDecider<S> decider)

Rank the services of a search with a specific ranker.

rankServicesWithScores

public static <S> ITerminableIntermediateFuture<Tuple2<S,java.lang.Double>> rankServicesWithScores(ITerminableIntermediateFuture<S> searchfut,
                                                                                                   IServiceRanker<S> ranker,
                                                                                                   IRankingSearchTerminationDecider<S> decider)

Rank the services of a search with a specific ranker and emit the scores.

getLocalReferenceInfo

public static boolean[] getLocalReferenceInfo(java.lang.reflect.Method method,
                                              boolean refdef)

Get the copy info for method parameters.

getRemoteReferenceInfo

public static boolean[] getRemoteReferenceInfo(java.lang.reflect.Method method,
                                               boolean refdef)

Get the copy info for method parameters.

getReferenceInfo

public static boolean[] getReferenceInfo(java.lang.reflect.Method method,
                                         boolean refdef,
                                         boolean local)

Get the copy info for method parameters.

isReturnValueLocalReference

public static boolean isReturnValueLocalReference(java.lang.reflect.Method method,
                                                  boolean refdef)

Test if return value is local reference.

isReturnValueRemoteReference

public static boolean isReturnValueRemoteReference(java.lang.reflect.Method method,
                                                   boolean refdef)

Get the copy info for method parameters.

createRequiredProxy

protected static <T> T createRequiredProxy(IInternalAccess component,
                                           T ser,
                                           java.lang.Class<?> type)

Create a required service proxy.

createRequiredProxies

protected static <T> java.util.Collection<T> createRequiredProxies(IInternalAccess component,
                                                                   java.util.Collection<T> sers,
                                                                   java.lang.Class<?> type)

Create a required service proxies.

checkThreadAccess

protected static void checkThreadAccess(IInternalAccess component,
                                        boolean proxy)

Check thread access and throw exception if is not component thread.

checkComponent

protected static void checkComponent(IInternalAccess component)

Check access not null and throw exception otherwise.

ensureThreadAccess

protected static IFuture<java.lang.Void> ensureThreadAccess(IInternalAccess component,
                                                            boolean proxy)

Check access not null and throw exception otherwise.