com.gigaspaces.internal.client.spaceproxy.router

Class SpaceProxyRouter

java.lang.Object

com.gigaspaces.internal.client.spaceproxy.router.SpaceProxyRouter

public class SpaceProxyRouter
extends Object

Since:

9.0.0

Author:

Niv Ingberg

Constructor Summary

Constructors

Constructor and Description
SpaceProxyRouter(SpaceProxyImpl spaceProxy)
SpaceProxyRouter(SpaceProxyImpl spaceProxy, int partitionNum)

Method Summary

Modifier and Type	Method and Description
void	close() Closes this space proxy router.
<T extends SpaceOperationResult> void	execute(RemoteOperationRequest<T> request)
<T extends SpaceOperationResult> RemoteOperationFutureListener<T>	executeAsync(RemoteOperationRequest<T> request, AsyncFutureListener<Object> listener)
void	executeOneway(RemoteOperationRequest<?> request)
List<IRemoteSpace>	getAllAvailableSpaces()
IRemoteSpace	getAnyActiveSpace()
IRemoteSpace	getAnyAvailableSpace()
IAsyncHandlerProvider	getAsyncHandlerProvider()
int	getChunksMapGeneration()
RemoteOperationsExecutorsClusterConfig	getConfig()
SpaceContext	getDefaultSpaceContext()
SpaceURL	getMemberUrl(String memberName)
SpaceProxyRemoteOperationRouter	getOperationRouter()
SpaceURL	getPrimaryMemberUrl(int partitionId)
RemoteSpaceProxyLocator	getProxyLocator()
void	setQuiesceToken(QuiesceToken token)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpaceProxyRouter

public SpaceProxyRouter(SpaceProxyImpl spaceProxy)

SpaceProxyRouter

public SpaceProxyRouter(SpaceProxyImpl spaceProxy,
                        int partitionNum)

Method Detail

getAsyncHandlerProvider

public IAsyncHandlerProvider getAsyncHandlerProvider()

close

public void close()

Closes this space proxy router. should be executed under a lock.

execute

public <T extends SpaceOperationResult> void execute(RemoteOperationRequest<T> request)
                                              throws InterruptedException

Throws:

InterruptedException

executeAsync

public <T extends SpaceOperationResult> RemoteOperationFutureListener<T> executeAsync(RemoteOperationRequest<T> request,
                                                                                      AsyncFutureListener<Object> listener)

executeOneway

public void executeOneway(RemoteOperationRequest<?> request)
                   throws InterruptedException

Throws:

InterruptedException

getConfig

public RemoteOperationsExecutorsClusterConfig getConfig()

getAnyAvailableSpace

public IRemoteSpace getAnyAvailableSpace()

getAnyActiveSpace

public IRemoteSpace getAnyActiveSpace()

getAllAvailableSpaces

public List<IRemoteSpace> getAllAvailableSpaces()

getMemberUrl

public SpaceURL getMemberUrl(String memberName)

getPrimaryMemberUrl

public SpaceURL getPrimaryMemberUrl(int partitionId)

getProxyLocator

public RemoteSpaceProxyLocator getProxyLocator()

getDefaultSpaceContext

public SpaceContext getDefaultSpaceContext()

getChunksMapGeneration

public int getChunksMapGeneration()

setQuiesceToken

public void setQuiesceToken(QuiesceToken token)

getOperationRouter

public SpaceProxyRemoteOperationRouter getOperationRouter()