jadex.bridge.service.component

Class BasicServiceInvocationHandler

java.lang.Object

jadex.bridge.service.component.BasicServiceInvocationHandler

All Implemented Interfaces:

ISwitchCall, InvocationHandler

public class BasicServiceInvocationHandler
extends Object
implements InvocationHandler, ISwitchCall

Basic service invocation interceptor. It has a multi collection of interceptors per method. Executes the list of interceptors one by one. In case no handler can be found a fallback handler is used.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROXYTYPE_DECOUPLED The (default) decoupled proxy type (decouples from caller thread to component thread).
static String	PROXYTYPE_DIRECT The direct proxy type (supports custom interceptors, but uses caller thread).
static String	PROXYTYPE_RAW The raw proxy type (i.e. no proxy).

Constructor Summary

Constructors

Constructor and Description
BasicServiceInvocationHandler(IInternalAccess comp, IServiceIdentifier sid, Logger logger, boolean realtime, Cause cause, boolean required) Create a new invocation handler.
BasicServiceInvocationHandler(IInternalAccess comp, IService service, Logger logger, boolean realtime, Cause cause, boolean required) Create a new invocation handler.
BasicServiceInvocationHandler(IInternalAccess comp, ServiceInfo service, Logger logger, boolean realtime, Cause cause) Create a new invocation handler.

Method Summary

Methods

Modifier and Type	Method and Description
void	addFirstServiceInterceptor(IServiceInvocationInterceptor interceptor) Add an interceptor.
static void	addPojoServiceProxy(Object pojo, IService proxy) Add a service proxy.
void	addServiceInterceptor(IServiceInvocationInterceptor interceptor) Add an interceptor.
void	addServiceInterceptor(IServiceInvocationInterceptor interceptor, int pos) Add an interceptor.
static IInternalService	createDelegationProvidedServiceProxy(IInternalAccess ia, IComponentAdapter adapter, IServiceIdentifier sid, RequiredServiceInfo info, RequiredServiceBinding binding, ClassLoader classloader, boolean realtime) Static method for creating a delegation service proxy for provided service that is not offered by the component itself.
static IInternalService	createProvidedServiceProxy(IInternalAccess ia, IComponentAdapter adapter, Object service, String name, Class<?> type, String proxytype, IServiceInvocationInterceptor[] ics, boolean copy, boolean realtime, IResourceIdentifier rid, boolean monitoring, IResultCommand<Object,Class<?>> componentfetcher) Static method for creating a standard service proxy for a provided service.
static IService	createRequiredServiceProxy(IInternalAccess ia, IExternalAccess ea, IComponentAdapter adapter, IService service, IRequiredServiceFetcher fetcher, RequiredServiceInfo info, RequiredServiceBinding binding, boolean realtime) Static method for creating a standard service proxy for a required service.
boolean	equals(Object obj) Test if two objects are equal.
Object	getDomainService() Get the domain service.
IServiceInvocationInterceptor[]	getInterceptors() Get interceptors.
static IService	getPojoServiceProxy(Object pojo) Get the proxy of a pojo service.
Object	getService() Get the service.
IServiceIdentifier	getServiceIdentifier() Get the sid.
int	hashCode() Return the hash code.
Object	invoke(Object proxy, Method method, Object[] args) A proxy method has been invoked.
boolean	isRequired() Check if the handler is for a required service proxy.
boolean	isSwitchCall() Check if a switch call should be done.
static void	removePojoServiceProxy(IServiceIdentifier sid) Remove a pojo - proxy pair.
void	removeServiceInterceptor(IServiceInvocationInterceptor interceptor) Remove an interceptor.
String	toString() Get a string representation.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Detail

PROXYTYPE_RAW

public static final String PROXYTYPE_RAW

The raw proxy type (i.e. no proxy).

See Also:

Constant Field Values

PROXYTYPE_DIRECT

public static final String PROXYTYPE_DIRECT

The direct proxy type (supports custom interceptors, but uses caller thread).

See Also:

Constant Field Values

PROXYTYPE_DECOUPLED

public static final String PROXYTYPE_DECOUPLED

The (default) decoupled proxy type (decouples from caller thread to component thread).

See Also:

Constant Field Values

Constructor Detail

BasicServiceInvocationHandler

public BasicServiceInvocationHandler(IInternalAccess comp,
                             IServiceIdentifier sid,
                             Logger logger,
                             boolean realtime,
                             Cause cause,
                             boolean required)

Create a new invocation handler.

BasicServiceInvocationHandler

public BasicServiceInvocationHandler(IInternalAccess comp,
                             IService service,
                             Logger logger,
                             boolean realtime,
                             Cause cause,
                             boolean required)

Create a new invocation handler.

BasicServiceInvocationHandler

public BasicServiceInvocationHandler(IInternalAccess comp,
                             ServiceInfo service,
                             Logger logger,
                             boolean realtime,
                             Cause cause)

Create a new invocation handler.

Method Detail

invoke

public Object invoke(Object proxy,
            Method method,
            Object[] args)
              throws Throwable

A proxy method has been invoked.

Specified by:

invoke in interface InvocationHandler

Throws:

Throwable

getServiceIdentifier

public IServiceIdentifier getServiceIdentifier()

Get the sid.

Returns:

the sid.

getService

public Object getService()

Get the service.

Returns:

The service.

getDomainService

public Object getDomainService()

Get the domain service.

Returns:

The domain service.

addFirstServiceInterceptor

public void addFirstServiceInterceptor(IServiceInvocationInterceptor interceptor)

Add an interceptor. Must be synchronized as invoke() is called from arbitrary threads.

addServiceInterceptor

public void addServiceInterceptor(IServiceInvocationInterceptor interceptor,
                         int pos)

Add an interceptor. Must be synchronized as invoke() is called from arbitrary threads.

addServiceInterceptor

public void addServiceInterceptor(IServiceInvocationInterceptor interceptor)

Add an interceptor. Must be synchronized as invoke() is called from arbitrary threads.

removeServiceInterceptor

public void removeServiceInterceptor(IServiceInvocationInterceptor interceptor)

Remove an interceptor. Must be synchronized as invoke() is called from arbitrary threads.

getInterceptors

public IServiceInvocationInterceptor[] getInterceptors()

Get interceptors. Must be synchronized as invoke() is called from arbitrary threads.

hashCode

public int hashCode()

Return the hash code.

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Test if two objects are equal.

Overrides:

equals in class Object

toString

public String toString()

Get a string representation.

Overrides:

toString in class Object

createProvidedServiceProxy

public static IInternalService createProvidedServiceProxy(IInternalAccess ia,
                                          IComponentAdapter adapter,
                                          Object service,
                                          String name,
                                          Class<?> type,
                                          String proxytype,
                                          IServiceInvocationInterceptor[] ics,
                                          boolean copy,
                                          boolean realtime,
                                          IResourceIdentifier rid,
                                          boolean monitoring,
                                          IResultCommand<Object,Class<?>> componentfetcher)

Static method for creating a standard service proxy for a provided service.

createDelegationProvidedServiceProxy

public static IInternalService createDelegationProvidedServiceProxy(IInternalAccess ia,
                                                    IComponentAdapter adapter,
                                                    IServiceIdentifier sid,
                                                    RequiredServiceInfo info,
                                                    RequiredServiceBinding binding,
                                                    ClassLoader classloader,
                                                    boolean realtime)

Static method for creating a delegation service proxy for provided service that is not offered by the component itself.

createRequiredServiceProxy

public static IService createRequiredServiceProxy(IInternalAccess ia,
                                  IExternalAccess ea,
                                  IComponentAdapter adapter,
                                  IService service,
                                  IRequiredServiceFetcher fetcher,
                                  RequiredServiceInfo info,
                                  RequiredServiceBinding binding,
                                  boolean realtime)

Static method for creating a standard service proxy for a required service.

addPojoServiceProxy

public static void addPojoServiceProxy(Object pojo,
                       IService proxy)

Add a service proxy.

Parameters:

pojo - The pojo.

proxy - The proxy.

removePojoServiceProxy

public static void removePojoServiceProxy(IServiceIdentifier sid)

Remove a pojo - proxy pair.

Parameters:

sid - The service identifier.

getPojoServiceProxy

public static IService getPojoServiceProxy(Object pojo)

Get the proxy of a pojo service.

Parameters:

pojo - The pojo service.

Returns:

The proxy of the service.

isSwitchCall

public boolean isSwitchCall()

Check if a switch call should be done.

Specified by:

isSwitchCall in interface ISwitchCall

Returns:

True, if switch should be done.

isRequired

public boolean isRequired()

Check if the handler is for a required service proxy.