jadex.bridge.service.component

Class DefaultServiceFetcher

java.lang.Object

jadex.bridge.service.component.DefaultServiceFetcher

All Implemented Interfaces:

IRequiredServiceFetcher

public class DefaultServiceFetcher
extends java.lang.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.

Field Summary

Fields

Modifier and Type	Field and Description
protected IInternalAccess	ia The internal access.
protected boolean	realtime The realtime flag for call timeouts.
protected java.lang.Object	result The cached result.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected <T> IFuture<T>	checkResult(T result, boolean rebind, RequiredServiceBinding bd)
protected <T> IIntermediateFuture<T>	checkResults(java.util.List<T> results, boolean rebind, RequiredServiceBinding bd)
protected IFuture<IExternalAccess>	createComponent(IInternalAccess provider, RequiredServiceInfo info, RequiredServiceBinding binding) Create component and get external access for component.
protected IFuture<IComponentIdentifier>	createComponentIdentifier(IInternalAccess provider, java.lang.String name, IComponentIdentifier parent) Create component identifier from name.
<T> IFuture<T>	createProxy(IService service, RequiredServiceInfo info, RequiredServiceBinding binding) Create a required service proxy.
java.util.Map<java.lang.String,java.lang.Object>	getArguments(ComponentInstanceInfo component, java.lang.String[] imports, IValueFetcher fetcher, java.lang.ClassLoader cl) Get the arguments.
IFuture<java.util.Collection<IExternalAccess>>	getChildExternalAccesses(IComponentIdentifier cid, IInternalAccess provider, RequiredServiceInfo info, RequiredServiceBinding binding) Get a fitting (of given type) child component.
protected IFuture<IExternalAccess>	getExternalAccess(IInternalAccess provider, IComponentIdentifier cid) Get external access for component identifier.
protected IFuture<IExternalAccess>	getExternalAccess(IInternalAccess provider, java.lang.String name, IComponentIdentifier parent) Get external access for component name.
protected IFuture<IExternalAccess>	getExternalAccessByName(IInternalAccess provider, RequiredServiceInfo info, RequiredServiceBinding binding) Get the external access of a component by its name.
protected IFuture<java.util.Collection<IExternalAccess>>	getExternalAccessesByType(IInternalAccess provider, RequiredServiceInfo info, RequiredServiceBinding binding) Get the external access of a component by type.
<T> T	getLastService() Get the result of the last search.
<T> java.util.Collection<T>	getLastServices() Get the result of the last search.
IFuture<IExternalAccess>	getParentAccess(IInternalAccess provider, RequiredServiceInfo info, RequiredServiceBinding binding)
<T> IFuture<T>	getService(RequiredServiceInfo info, RequiredServiceBinding bd, boolean rebind, IAsyncFilter<T> filter) Get a required service.
<T> ITerminableIntermediateFuture<T>	getServices(RequiredServiceInfo info, RequiredServiceBinding bd, boolean rebind, IAsyncFilter<T> filter) Get a required multi service.

Methods inherited from class java.lang.Object

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

Field Detail

ia

protected IInternalAccess ia

The internal access.

result

protected java.lang.Object result

The cached result.

realtime

protected boolean realtime

The realtime flag for call timeouts.

Constructor Detail

DefaultServiceFetcher

public DefaultServiceFetcher(IInternalAccess ia,
                             boolean realtime)

Create a new required service fetcher.

Method Detail

getService

public <T> IFuture<T> getService(RequiredServiceInfo info,
                                 RequiredServiceBinding bd,
                                 boolean rebind,
                                 IAsyncFilter<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> ITerminableIntermediateFuture<T> getServices(RequiredServiceInfo info,
                                                        RequiredServiceBinding bd,
                                                        boolean rebind,
                                                        IAsyncFilter<T> filter)

Get a required multi service. todo: implement filter todo: implement termination!!!! 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.

getLastService

public <T> T getLastService()

Get the result of the last search.

Specified by:

getLastService in interface IRequiredServiceFetcher

getLastServices

public <T> java.util.Collection<T> getLastServices()

Get the result of the last search.

Specified by:

getLastServices in interface IRequiredServiceFetcher

checkResults

protected <T> IIntermediateFuture<T> checkResults(java.util.List<T> results,
                                                  boolean rebind,
                                                  RequiredServiceBinding bd)

checkResult

protected <T> IFuture<T> checkResult(T result,
                                     boolean rebind,
                                     RequiredServiceBinding bd)

getExternalAccessByName

protected IFuture<IExternalAccess> getExternalAccessByName(IInternalAccess provider,
                                                           RequiredServiceInfo info,
                                                           RequiredServiceBinding binding)

Get the external access of a component by its name.

getExternalAccessesByType

protected IFuture<java.util.Collection<IExternalAccess>> getExternalAccessesByType(IInternalAccess provider,
                                                                                   RequiredServiceInfo info,
                                                                                   RequiredServiceBinding binding)

Get the external access of a component by type.

getChildExternalAccesses

public IFuture<java.util.Collection<IExternalAccess>> getChildExternalAccesses(IComponentIdentifier cid,
                                                                               IInternalAccess provider,
                                                                               RequiredServiceInfo info,
                                                                               RequiredServiceBinding binding)

Get a fitting (of given type) child component.

createComponentIdentifier

protected IFuture<IComponentIdentifier> createComponentIdentifier(IInternalAccess provider,
                                                                  java.lang.String name,
                                                                  IComponentIdentifier parent)

Create component identifier from name.

getExternalAccess

protected IFuture<IExternalAccess> getExternalAccess(IInternalAccess provider,
                                                     IComponentIdentifier cid)

Get external access for component identifier.

getExternalAccess

protected IFuture<IExternalAccess> getExternalAccess(IInternalAccess provider,
                                                     java.lang.String name,
                                                     IComponentIdentifier parent)

Get external access for component name.

createComponent

protected IFuture<IExternalAccess> createComponent(IInternalAccess provider,
                                                   RequiredServiceInfo info,
                                                   RequiredServiceBinding binding)

Create component and get external access for component.

getArguments

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

Get the arguments.

Returns:

The arguments as a map of name-value pairs.

getParentAccess

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

createProxy

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

Create a required service proxy.