org.openspaces.remoting
Class ExecutorRemotingProxyConfigurer<T>

java.lang.Object
  org.openspaces.remoting.ExecutorRemotingProxyConfigurer<T>

public class ExecutorRemotingProxyConfigurer<T>
extends Object

A simple programmatic configurer creating a remote executor based proxy

Usage example:

 IJSpace space = new UrlSpaceConfigurer("jini://*/*/mySpace")
                        .space();
 GigaSpace gigaSpace = new GigaSpaceConfigurer(space).gigaSpace();
 MyBusinessInterface proxy = new ExecutorRemotingProxyConfigurer<MyBusinessInterface>(gigaSpace, MyBusinessInterface.class)
                                         .broadcast(true)
                                         .proxy();
 proxy.businessMethod(...);
 

Author:

kimchy

Constructor Summary

ExecutorRemotingProxyConfigurer(GigaSpace gigaSpace, Class<T> serviceInterface)

Method Summary

ExecutorRemotingProxyConfigurer<T>	broadcast(boolean broadcast)
<X,Y> ExecutorRemotingProxyConfigurer<T>	broadcast(RemoteResultReducer<X,Y> remoteResultReducer)
ExecutorRemotingProxyConfigurer<T>	metaArgumentsHandler(MetaArgumentsHandler metaArgumentsHandler)
T	proxy() Creates a new executor proxy of type T
ExecutorRemotingProxyConfigurer<T>	remoteInvocationAspect(RemoteInvocationAspect remoteInvocationAspect)
ExecutorRemotingProxyConfigurer<T>	remoteResultReducer(RemoteResultReducer remoteResultReducer)
ExecutorRemotingProxyConfigurer<T>	remoteRoutingHandler(RemoteRoutingHandler remoteRoutingHandler)
ExecutorRemotingProxyConfigurer<T>	returnFirstResult(boolean returnFirstResult)
ExecutorRemotingProxyConfigurer<T>	timeout(long timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorRemotingProxyConfigurer

public ExecutorRemotingProxyConfigurer(GigaSpace gigaSpace,
                                       Class<T> serviceInterface)

Method Detail

timeout

public ExecutorRemotingProxyConfigurer<T> timeout(long timeout)

See Also:

ExecutorSpaceRemotingProxyFactoryBean.setTimeout(long)

broadcast

public ExecutorRemotingProxyConfigurer<T> broadcast(boolean broadcast)

See Also:

ExecutorSpaceRemotingProxyFactoryBean.setBroadcast(boolean)

broadcast

public <X,Y> ExecutorRemotingProxyConfigurer<T> broadcast(RemoteResultReducer<X,Y> remoteResultReducer)

See Also:

ExecutorSpaceRemotingProxyFactoryBean.setBroadcast(boolean), ExecutorSpaceRemotingProxyFactoryBean.setRemoteResultReducer(org.openspaces.remoting.RemoteResultReducer)

remoteResultReducer

public ExecutorRemotingProxyConfigurer<T> remoteResultReducer(RemoteResultReducer remoteResultReducer)

See Also:

ExecutorSpaceRemotingProxyFactoryBean.setRemoteResultReducer(org.openspaces.remoting.RemoteResultReducer)

returnFirstResult

public ExecutorRemotingProxyConfigurer<T> returnFirstResult(boolean returnFirstResult)

See Also:

ExecutorSpaceRemotingProxyFactoryBean.setReturnFirstResult(boolean)

metaArgumentsHandler

public ExecutorRemotingProxyConfigurer<T> metaArgumentsHandler(MetaArgumentsHandler metaArgumentsHandler)

See Also:

ExecutorSpaceRemotingProxyFactoryBean.setMetaArgumentsHandler(MetaArgumentsHandler)

remoteInvocationAspect

public ExecutorRemotingProxyConfigurer<T> remoteInvocationAspect(RemoteInvocationAspect remoteInvocationAspect)

See Also:

ExecutorSpaceRemotingProxyFactoryBean.remoteInvocationAspect

remoteRoutingHandler

public ExecutorRemotingProxyConfigurer<T> remoteRoutingHandler(RemoteRoutingHandler remoteRoutingHandler)

See Also:

ExecutorSpaceRemotingProxyFactoryBean.setRemoteRoutingHandler(RemoteRoutingHandler)

proxy

public T proxy()

Creates a new executor proxy of type T