com.gigaspaces.internal.client.spaceproxy.router

Class SpaceEmbeddedRemoteOperationRouter

java.lang.Object

com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

com.gigaspaces.internal.remoting.routing.embedded.EmbeddedRemoteOperationRouter

com.gigaspaces.internal.client.spaceproxy.router.SpaceEmbeddedRemoteOperationRouter

All Implemented Interfaces:

SpaceProxyRemoteOperationRouter, RemoteOperationRouter

public class SpaceEmbeddedRemoteOperationRouter
extends EmbeddedRemoteOperationRouter
implements SpaceProxyRemoteOperationRouter

Embedded space remote operations router.

Since:

9.0.0

Author:

idan

Field Summary

Fields inherited from class com.gigaspaces.internal.remoting.routing.embedded.EmbeddedRemoteOperationRouter

_executor, _memberProxy

Fields inherited from class com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

_logger

Constructor Summary

Constructors

Constructor and Description
SpaceEmbeddedRemoteOperationRouter(SpaceProxyImpl spaceProxy, int partitionId, QuiesceTokenProvider quiesceTokenProvider)

Method Summary

Modifier and Type	Method and Description
protected void	afterOperationExecution(RemoteOperationRequest<?> request)
protected boolean	beforeOperationExecution(RemoteOperationRequest<?> request)
String	getActiveMemberName(int partitionId)

Methods inherited from class com.gigaspaces.internal.remoting.routing.embedded.EmbeddedRemoteOperationRouter

close, createFutureListener, execute, executeAsync, executeOneway, getAllAvailableMembers, getAnyActiveMember, getAnyAvailableCachedMember, getAnyAvailableMember, getCachedMember, getExecutor, getName, getPartitionId

Methods inherited from class com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

logAfterExecute, logAfterExecuteAsync, logAsyncExecutionFailure, logBeforeExecute, logBeforeExecuteAsync, logExecutionFailure, logInterruptedAsyncExecution, logInterruptedExecution, logUnexpectedAsyncExecution

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.remoting.routing.RemoteOperationRouter

close, createFutureListener, execute, executeAsync, executeOneway, getAllAvailableMembers, getAnyActiveMember, getAnyAvailableCachedMember, getAnyAvailableMember, getCachedMember

Constructor Detail

SpaceEmbeddedRemoteOperationRouter

public SpaceEmbeddedRemoteOperationRouter(SpaceProxyImpl spaceProxy,
                                          int partitionId,
                                          QuiesceTokenProvider quiesceTokenProvider)

Method Detail

beforeOperationExecution

protected boolean beforeOperationExecution(RemoteOperationRequest<?> request)

Overrides:

beforeOperationExecution in class EmbeddedRemoteOperationRouter

afterOperationExecution

protected void afterOperationExecution(RemoteOperationRequest<?> request)

Overrides:

afterOperationExecution in class EmbeddedRemoteOperationRouter

getActiveMemberName

public String getActiveMemberName(int partitionId)

Specified by:

getActiveMemberName in interface SpaceProxyRemoteOperationRouter