GigaSpaces XAP 7.0 API

org.openspaces.remoting
Class EventDrivenSpaceRemotingProxyFactoryBean

java.lang.Object
  extended by org.springframework.remoting.support.RemotingSupport
      extended by org.springframework.remoting.support.RemoteAccessor
          extended by org.openspaces.remoting.EventDrivenSpaceRemotingProxyFactoryBean
All Implemented Interfaces:
Advice, Interceptor, MethodInterceptor, RemotingInvoker, BeanClassLoaderAware, FactoryBean, InitializingBean
Direct Known Subclasses:
AsyncSpaceRemotingProxyFactoryBean

public class EventDrivenSpaceRemotingProxyFactoryBean
extends RemoteAccessor
implements FactoryBean, InitializingBean, MethodInterceptor, RemotingInvoker

A space event driven remoting proxy that forward the service execution to a remote service with the space as the transport layer. Services are remotely exported in the "server side" using the SpaceRemotingServiceExporter which in turn is registered with an event container. This proxy builds a representation of the remote invocation using EventDrivenSpaceRemotingEntry and waits for a remoting response represented by EventDrivenSpaceRemotingEntry.

The proxy requires a setGigaSpace(org.openspaces.core.GigaSpace) interface to be set in order to write the remote invocation and wait for a response using the space API. It also requires a RemoteAccessor.setServiceInterface(Class) which represents the interface that will be proxied.

Allows for one way invocations (i.e. not waiting for a response). The one way invocation can be set globally for all of the service methods by setting setGlobalOneWay(boolean) or can be enabled only for methods that return void by setting setVoidOneWay(boolean). Note, if using one way invocation and an exception is raised by the remote service, it won't be raised by this proxy.

A timeout which controls how long the proxy will wait for the response can be set using setTimeout(long). The timeout value if in milliseconds.

The space remote proxy supports a future based invocation. This means that if, on the client side, one of the service interface methods returns Future, it can be used for async execution. Note, this means that in terms of interfaces there will have to be two different service interfaces (under the same package and with the same name). One for the server side service that returns the actual value, and one on the client side that for the same method simply returns the future. Another option is not having two different interfaces, but having the same interface with async methods (returning Future). The async methods should start with a specified prefix (defaults to async) and should have no implementation on the server side (simply return null).

In case of remote invocation over a partitioned space the default partitioned routing index will be random (the hashCode of the newly created EventDrivenSpaceRemotingEntry class). The proxy allows for a pluggable routing handler implementation by setting setRemoteRoutingHandler(RemoteRoutingHandler).

The actual remote invocation can be replaced with an aspect implementing RemoteInvocationAspect which can be set using setRemoteInvocationAspect(RemoteInvocationAspect). It is up the aspect to then call the actual remote invocation.

Author:
kimchy
See Also:
SpaceRemotingServiceExporter

Field Summary
static String DEFAULT_ASYNC_METHOD_PREFIX
           
 
Fields inherited from class org.springframework.remoting.support.RemotingSupport
logger
 
Constructor Summary
EventDrivenSpaceRemotingProxyFactoryBean()
           
 
Method Summary
 void afterPropertiesSet()
           
 Object getObject()
           
 Class<?> getObjectType()
           
 Object invoke(MethodInvocation methodInvocation)
           
 Object invokeRemote(MethodInvocation methodInvocation)
          This invocation will cause the actual remote invocation.
 boolean isSingleton()
           
 void setAsyncMethodPrefix(String asyncMethodPrefix)
          Sets the async method prefix.
 void setFifo(boolean fifo)
          Sets the remote invocation objects written to the Space to work in FIFO.
 void setGigaSpace(GigaSpace gigaSpace)
          Sets the GigaSpace interface that will be used to work with the space as the transport layer for both writing and taking EventDrivenSpaceRemotingEntry.
 void setGlobalOneWay(boolean globalOneWay)
          If set to true (defaults to false) all of the service methods will be invoked and the proxy will not wait for a return value.
 void setMetaArgumentsHandler(MetaArgumentsHandler metaArgumentsHandler)
          Allows to set a meta argument handler that will control SpaceRemotingInvocation.getMetaArguments().
 void setRemoteInvocationAspect(RemoteInvocationAspect remoteInvocationAspect)
          The actual remote invocation can be replaced with an aspect implementing RemoteInvocationAspect which can be set using setRemoteInvocationAspect(RemoteInvocationAspect).
 void setRemoteRoutingHandler(RemoteRoutingHandler remoteRoutingHandler)
          In case of remote invocation over a partitioned space the default partitioned routing index will be random (the hashCode of the newly created EventDrivenSpaceRemotingEntry class).
 void setTimeout(long timeout)
          Sets the timeout that will be used to wait for the remote invocation response.
 void setVoidOneWay(boolean voidOneWay)
          If set to true (defaults to false) service methods that return void will be invoked and the proxy will not wait for a return value.
 
Methods inherited from class org.springframework.remoting.support.RemoteAccessor
getServiceInterface, setServiceInterface
 
Methods inherited from class org.springframework.remoting.support.RemotingSupport
getBeanClassLoader, overrideThreadContextClassLoader, resetThreadContextClassLoader, setBeanClassLoader
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_ASYNC_METHOD_PREFIX

public static final String DEFAULT_ASYNC_METHOD_PREFIX
See Also:
Constant Field Values
Constructor Detail

EventDrivenSpaceRemotingProxyFactoryBean

public EventDrivenSpaceRemotingProxyFactoryBean()
Method Detail

setGigaSpace

public void setGigaSpace(GigaSpace gigaSpace)
Sets the GigaSpace interface that will be used to work with the space as the transport layer for both writing and taking EventDrivenSpaceRemotingEntry.


setTimeout

public void setTimeout(long timeout)
Sets the timeout that will be used to wait for the remote invocation response. The timeout value is in milliseconds and defaults to 60000 (60 seconds).


setRemoteRoutingHandler

public void setRemoteRoutingHandler(RemoteRoutingHandler remoteRoutingHandler)
In case of remote invocation over a partitioned space the default partitioned routing index will be random (the hashCode of the newly created EventDrivenSpaceRemotingEntry class). This RemoteRoutingHandler allows for custom routing computation (for example, based on one of the service method parameters).


setMetaArgumentsHandler

public void setMetaArgumentsHandler(MetaArgumentsHandler metaArgumentsHandler)
Allows to set a meta argument handler that will control SpaceRemotingInvocation.getMetaArguments().


setGlobalOneWay

public void setGlobalOneWay(boolean globalOneWay)
If set to true (defaults to false) all of the service methods will be invoked and the proxy will not wait for a return value. Note, any exception raised by the remote service will be logged on the server side and not propagated to the client.


setVoidOneWay

public void setVoidOneWay(boolean voidOneWay)
If set to true (defaults to false) service methods that return void will be invoked and the proxy will not wait for a return value. Note, any exception raised by the remote service will be logged on the server side and not propagated to the client.


setFifo

public void setFifo(boolean fifo)
Sets the remote invocation objects written to the Space to work in FIFO. Note, when setting this setting make sure to set it on the SpaceRemotingServiceExporter. This allows for remoting to work in fifo mode without needing to set the whole Space to work in fifo mode.


setAsyncMethodPrefix

public void setAsyncMethodPrefix(String asyncMethodPrefix)
Sets the async method prefix. Defaults to DEFAULT_ASYNC_METHOD_PREFIX.


setRemoteInvocationAspect

public void setRemoteInvocationAspect(RemoteInvocationAspect remoteInvocationAspect)
The actual remote invocation can be replaced with an aspect implementing RemoteInvocationAspect which can be set using setRemoteInvocationAspect(RemoteInvocationAspect). It is up the aspect to then call the actual remote invocation.


afterPropertiesSet

public void afterPropertiesSet()
Specified by:
afterPropertiesSet in interface InitializingBean

getObject

public Object getObject()
Specified by:
getObject in interface FactoryBean

getObjectType

public Class<?> getObjectType()
Specified by:
getObjectType in interface FactoryBean

isSingleton

public boolean isSingleton()
Specified by:
isSingleton in interface FactoryBean

invoke

public Object invoke(MethodInvocation methodInvocation)
              throws Throwable
Specified by:
invoke in interface MethodInterceptor
Throws:
Throwable

invokeRemote

public Object invokeRemote(MethodInvocation methodInvocation)
                    throws Throwable
Description copied from interface: RemotingInvoker
This invocation will cause the actual remote invocation.

Specified by:
invokeRemote in interface RemotingInvoker
Throws:
Throwable

GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.