jadex.bridge.service.component

Class DefaultServiceFetcher

java.lang.Object

jadex.bridge.service.component.DefaultServiceFetcher

All Implemented Interfaces:

IRequiredServiceFetcher

public class DefaultServiceFetcher
extends Object
implements IRequiredServiceFetcher

The default service fetcher realizes the default strategy for fetching a required service. Allows for: - binding by searching service(s) - binding by name - binding by type - dynamic or static binding - creation of components - recovery of failed services cannot be done here because failure occurs at time of service call

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DefaultServiceFetcher.StoreDelegationResultListener<T> Simple listener that can store the result in a member variable.
class	DefaultServiceFetcher.StoreIntermediateDelegationResultListener<T> Simple listener that can store the result in a member variable.

Constructor Summary

Constructors

Constructor and Description
DefaultServiceFetcher(IServiceProvider provider, IInternalAccess ia, boolean realtime) Create a new required service fetcher.

Method Summary

Methods

Modifier and Type	Method and Description
<T> IFuture<T>	createProxy(IService service, RequiredServiceInfo info, RequiredServiceBinding binding) Create a proxy.
Map<String,Object>	getArguments(ComponentInstanceInfo component, String[] imports, IValueFetcher fetcher, ClassLoader cl) Get the arguments.
IFuture<Collection<IExternalAccess>>	getChildExternalAccesses(IComponentIdentifier cid, IServiceProvider provider, RequiredServiceInfo info, RequiredServiceBinding binding) Get a fitting (of given type) child component.
IFuture<IExternalAccess>	getParentAccess(IServiceProvider provider, RequiredServiceInfo info, RequiredServiceBinding binding)
<T> IFuture<T>	getService(RequiredServiceInfo info, RequiredServiceBinding bd, boolean rebind, IFilter<T> filter) Get a required service.
<T> IIntermediateFuture<T>	getServices(RequiredServiceInfo info, RequiredServiceBinding bd, boolean rebind, IFilter<T> filter) Get a required multi service.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultServiceFetcher

public DefaultServiceFetcher(IServiceProvider provider,
                     IInternalAccess ia,
                     boolean realtime)

Create a new required service fetcher.

Method Detail

getService

public <T> IFuture<T> getService(RequiredServiceInfo info,
                        RequiredServiceBinding bd,
                        boolean rebind,
                        IFilter<T> filter)

Get a required service.

Specified by:

getService in interface IRequiredServiceFetcher

Parameters:

info - The service info.

rebind - Flag if should be rebound.

getServices

public <T> IIntermediateFuture<T> getServices(RequiredServiceInfo info,
                                     RequiredServiceBinding bd,
                                     boolean rebind,
                                     IFilter<T> filter)

Get a required multi service. todo: should also create component(s) when no service could be found

Specified by:

getServices in interface IRequiredServiceFetcher

Parameters:

info - The service info.

rebind - Flag if should be rebound.

getChildExternalAccesses

public IFuture<Collection<IExternalAccess>> getChildExternalAccesses(IComponentIdentifier cid,
                                                            IServiceProvider provider,
                                                            RequiredServiceInfo info,
                                                            RequiredServiceBinding binding)

Get a fitting (of given type) child component.

getArguments

public Map<String,Object> getArguments(ComponentInstanceInfo component,
                              String[] imports,
                              IValueFetcher fetcher,
                              ClassLoader cl)

Get the arguments.

Returns:

The arguments as a map of name-value pairs.

getParentAccess

public IFuture<IExternalAccess> getParentAccess(IServiceProvider provider,
                                       RequiredServiceInfo info,
                                       RequiredServiceBinding binding)

createProxy

public <T> IFuture<T> createProxy(IService service,
                         RequiredServiceInfo info,
                         RequiredServiceBinding binding)

Create a proxy.