Package com.gigaspaces.internal.client.spaceproxy

Class SpaceProxyImpl

java.lang.Object

com.gigaspaces.internal.client.spaceproxy.AbstractSpaceProxy

com.gigaspaces.internal.client.spaceproxy.AbstractDirectSpaceProxy

com.gigaspaces.internal.client.spaceproxy.SpaceProxyImpl

All Implemented Interfaces:

IPojoSpace, IDirectSpaceProxy, ISpaceProxy, IClusterInfoChangedListener, SecuredService, IDotnetProxyAssociated, SmartExternalizable, ActionMaker, IJSpace, Service, MarshalPivotProvider, Externalizable, Serializable, Remote, Administrable, ReferentUuid, SameProxyVersionProvider, JavaSpace

public class SpaceProxyImpl
extends AbstractDirectSpaceProxy
implements SameProxyVersionProvider, MarshalPivotProvider, IClusterInfoChangedListener

Provides the functionality of clustered proxy.

Since:

2.0

Version:

1.3

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	SpaceProxyImpl.Listener	This class is only used by the engine to verify that the proxy is alive.

Field Summary

Fields inherited from class com.gigaspaces.internal.client.spaceproxy.AbstractDirectSpaceProxy

_proxySettings

Fields inherited from interface com.j_spaces.core.IJSpace

NO_WAIT

Fields inherited from interface net.jini.space.JavaSpace

NO_WAIT

Constructor Summary

Constructors

Constructor	Description
SpaceProxyImpl(DirectSpaceProxyFactoryImpl factory, ProxySettings proxySettings)

Method Summary

Modifier and Type	Method	Description
void	afterClusterInfoChange(SpaceClusterInfo clusterInfo)	Updates server side components that holds SpaceClusterInfo instances when SpaceClusterInfo changes (i.e horizontal scale event)
static void	afterExecute(SpaceOperationRequest<?> spaceRequest, IRemoteSpace targetSpace, int partitionId, boolean isRejected)
boolean	beforeExecute(SpaceOperationRequest<?> spaceRequest, IRemoteSpace targetSpace, int partitionId, String clusterName, boolean isEmbedded)
Transaction	beforeSpaceAction()
void	beforeSpaceAction(CommonProxyActionInfo action)
Transaction	beforeSpaceAction(Transaction txn)
SpaceProxyImpl	cloneProxy()
void	close()	Close the proxy and execute necessary cleanup logic.
protected AbstractSpaceProxyActionManager<SpaceProxyImpl>	createActionManager()
OperationID	createNewOperationID()	Generate a unique operation ID
void	demote(long maxSuspendTime, TimeUnit timeUnit, CredentialsProvider credentialsProvider)	Internal demote API for swapping from primary to backup Space.
void	directClean()
void	directDropClass(String className)
boolean	equals(Object obj)	overrides implementation of equals() method in AbstractSpaceProxy
protected void	finalize()
Object	getAdmin()	Returns the admin object to the remote part of this space.
String	getCacheTypeName()
long	getClientID()
IJSpace	getClusteredProxy()	Returns a clustered view of this proxy.
IJSpaceContainer	getContainer()	Returns the container proxy this space resides in.
ContainerConfig	getContainerConfig()
SpaceURL	getContainerURL()
Transaction.Created	getContextTransaction()	Returns the transaction associated with the current context, if any.
SpaceProxyDataEventsManager	getDataEventsManager()
IDirectSpaceProxy	getDirectProxy()	returns itself in case of a direct proxy or the real proxy in case of a local cache or a view.
DirectSpaceProxyFactory	getFactory()
SpaceURL	getFinderURL()	Returns the SpaceURL object which was used as the argument for SpaceFinder.find(SpaceURL) while looking for the space.
MarshalPivot	getMarshalPivot()
String	getName()	Returns the name of this space.
IJSpace	getNonClusteredProxy()	Returns a proxy of the specified space.
IDirectSpaceProxy	getNotificationsDirectProxy()	returns itself in case of a direct proxy or the real proxy in case of a local cache or a view.
int	getPartitionId(Object routingValue)
Object	getPrivilegedAdmin()	Get remote admin object for this space.
SpaceProxyRouter	getProxyRouter()
IQueryManager	getQueryManager()
int	getReadModifiers()	Gets the proxy ReadModifiers.
Uuid	getReferentUuid()	Returns the unique Uuid of this space instance.
IRemoteSpace	getRemoteJSpace()	Returns the reference to initial remote space
String	getRemoteMemberName()
IProxySecurityManager	getSecurityManager()
SpaceClusterInfo	getSpaceClusterInfo()
SpaceImpl	getSpaceImplIfEmbedded()
IStubHandler	getStubHandler()	Returns the StubHandler of this space.
ExecutorService	getThreadPool()
ITypeDesc	getTypeDescFromServer(String typeName)
ISpaceProxyTypeManager	getTypeManager()
int	getUpdateModifiers()	Gets the proxyUpdateModifiers.
SpaceURL	getURL()	Returns the SpaceURL instance which was used to initialize the space.
Object	getVersion()
void	initProxyRouter(int partitionId)
int	initWriteModifiers(int modifiers)
boolean	isClustered()	returns true if the proxy is Clustered
boolean	isEmbedded()	Checks whether proxy is connected to embedded or remote space.
boolean	isFifo()	Returns true if this proxy FIFO enabled, otherwise false.
boolean	isGatewayProxy()
boolean	isOptimisticLockingEnabled()	Returns status of Optimistic Lock protocol.
boolean	isSecured()	Returns an indication : is this space secured.
boolean	isServiceSecured()	If a security model is defined will return true.
boolean	isStartedWithinGSC()	Returns true if the space started within a GSC.
Class<?>	loadRemoteClass(String className)	Loads a remote class from the space, the class will be loaded locally into a corresponding LRMIClassLoader
SecurityContext	login(CredentialsProvider credentialsProvider)	Login to a secured service using the provided credentialsProvider.
ISpaceQuery	prepareTemplate(Object template)
void	readExternal(ObjectInput in)
void	registerTypeDescInServers(ITypeDesc typeDesc)
Transaction.Created	replaceContextTransaction(Transaction.Created txn)
Transaction.Created	replaceContextTransaction(Transaction.Created transaction, ActionListener actionListener, boolean delegatedXa)
void	setActionListener(ActionListener actionListener)	Sets a new ActionListener to receive events.
void	setFifo(boolean enabled)	Sets FIFO mode for proxy.
void	setFinderURL(SpaceURL _finderurl)
void	setGatewayProxy()
void	setMVCCGenerationsState(MVCCGenerationsState generationsState)
void	setOptimisticLocking(boolean enabled)	Enable/Disable Optimistic Lock protocol.
void	setQuiesceToken(QuiesceToken token)
int	setReadModifiers(int readModifiers)	Sets the read mode modifiers for proxy level.
int	setUpdateModifiers(int newModifiers)	Sets the update mode modifiers for proxy level.
void	shutdown()
void	updateProxyRouter(SpaceProxyRouter oldRouter, ClusterTopology chunksMap)	Used in client side to update all proxy components with the new map
void	writeExternal(ObjectOutput out)

Methods inherited from class com.gigaspaces.internal.client.spaceproxy.AbstractDirectSpaceProxy

getProxySettings, hashCode, toString

Methods inherited from class com.gigaspaces.internal.client.spaceproxy.AbstractSpaceProxy

aggregate, applyNotifyInfoDefaults, asyncAddIndexes, asyncChange, asyncRead, asyncTake, change, checkIfConnected, clear, clear, count, count, dropClass, execute, execute, getAppDomainId, getContainerName, getDotnetProxyHandleId, getLocalSpace, getRemoteSpace, getSpaceHealthStatus, getTypeDescriptor, hasAssociatedAppDomain, isCacheContainer, isLocalCacheCacheContainer, isLocalViewContainer, isTargetOfADotnetProxy, notify, ping, read, read, read, read, readById, readById, readByIds, readByIds, readByIds, readByUid, readEntriesUids, readIfExists, readIfExists, readIfExists, readMultiple, readMultiple, readMultiple, readMultiple, registerTypeDescriptor, registerTypeDescriptor, setAppDomainId, setDotnetProxyHandleId, snapshot, snapshot, take, take, take, take, takeById, takeById, takeByIds, takeByIds, takeByIds, takeByUid, takeIfExists, takeIfExists, takeIfExists, takeMultiple, takeMultiple, takeMultiple, takeMultiple, unregisterTypeDescriptor, update, update, updateMultiple, updateMultiple, write, write, write, writeMultiple, writeMultiple, writeMultiple, writeMultiple, writeMultiple

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.gigaspaces.serialization.pbs.IDotnetProxyAssociated

getAppDomainId, getDotnetProxyHandleId, hasAssociatedAppDomain, isTargetOfADotnetProxy, setAppDomainId, setDotnetProxyHandleId

Methods inherited from interface com.j_spaces.core.IJSpace

dropClass, getContainerName, ping

Methods inherited from interface com.gigaspaces.client.IPojoSpace

clear, clear, count, count, read, read, readIfExists, readIfExists, readMultiple, readMultiple, snapshot, take, take, takeIfExists, takeMultiple, takeMultiple, update, update, updateMultiple, updateMultiple, write, write, writeMultiple, writeMultiple, writeMultiple

Methods inherited from interface com.gigaspaces.internal.client.spaceproxy.ISpaceProxy

aggregate, applyNotifyInfoDefaults, asyncAddIndexes, asyncChange, asyncRead, asyncTake, change, checkIfConnected, execute, execute, getSpaceHealthStatus, getTypeDescriptor, read, readById, readById, readByIds, readByIds, readByIds, readByUid, readEntriesUids, readMultiple, readMultiple, registerTypeDescriptor, registerTypeDescriptor, take, takeById, takeById, takeByIds, takeByIds, takeByIds, takeByUid, takeMultiple, takeMultiple, unregisterTypeDescriptor, writeMultiple

Methods inherited from interface net.jini.space.JavaSpace

notify, read, readIfExists, snapshot, take, takeIfExists, write

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

SpaceProxyImpl

public SpaceProxyImpl(DirectSpaceProxyFactoryImpl factory,
 ProxySettings proxySettings)

Method Details

getThreadPool

public ExecutorService getThreadPool()

Specified by:

getThreadPool in interface IDirectSpaceProxy

getDirectProxy

public IDirectSpaceProxy getDirectProxy()

Description copied from interface: IJSpace

returns itself in case of a direct proxy or the real proxy in case of a local cache or a view.

Specified by:

getDirectProxy in interface IJSpace

Returns:

IDirectSpaceProxy

getCacheTypeName

public String getCacheTypeName()

Specified by:

getCacheTypeName in interface IJSpace

getNotificationsDirectProxy

public IDirectSpaceProxy getNotificationsDirectProxy()

Description copied from interface: ISpaceProxy

returns itself in case of a direct proxy or the real proxy in case of a local cache or a view.

Specified by:

getNotificationsDirectProxy in interface ISpaceProxy

getQueryManager

public IQueryManager getQueryManager()

Specified by:

getQueryManager in interface IDirectSpaceProxy

getDataEventsManager

public SpaceProxyDataEventsManager getDataEventsManager()

Specified by:

getDataEventsManager in interface IDirectSpaceProxy

getSecurityManager

public IProxySecurityManager getSecurityManager()

Specified by:

getSecurityManager in interface IDirectSpaceProxy

getTypeManager

public ISpaceProxyTypeManager getTypeManager()

Specified by:

getTypeManager in interface IDirectSpaceProxy

setActionListener

public void setActionListener(ActionListener actionListener)

Description copied from interface: ActionMaker

Sets a new ActionListener to receive events. Replaces any former ActionListener if exists.

Specified by:

setActionListener in interface ActionMaker

getContextTransaction

public Transaction.Created getContextTransaction()

Description copied from interface: ISpaceProxy

Returns the transaction associated with the current context, if any.

Specified by:

getContextTransaction in interface ISpaceProxy

replaceContextTransaction

public Transaction.Created replaceContextTransaction(Transaction.Created txn)

Specified by:

replaceContextTransaction in interface ISpaceProxy

replaceContextTransaction

public Transaction.Created replaceContextTransaction(Transaction.Created transaction,
 ActionListener actionListener,
 boolean delegatedXa)

Specified by:

replaceContextTransaction in interface ISpaceProxy

getReferentUuid

public Uuid getReferentUuid()

Description copied from interface: IJSpace

Returns the unique Uuid of this space instance.

Specified by:

getReferentUuid in interface IJSpace

Specified by:

getReferentUuid in interface ReferentUuid

Returns:

the Uuid associated with the resource this proxy represents. Will not return null.

getName

public String getName()

Description copied from interface: IJSpace

Returns the name of this space.

Specified by:

getName in interface IJSpace

isEmbedded

public boolean isEmbedded()

Description copied from interface: IJSpace

Checks whether proxy is connected to embedded or remote space.

Specified by:

isEmbedded in interface IJSpace

isSecured

public boolean isSecured()

Description copied from interface: IJSpace

Returns an indication : is this space secured. If for this space defined Security Filter, the space will be secured.

Specified by:

isSecured in interface IJSpace

Returns:

boolean true if this space secured, otherwise false.

isServiceSecured

public boolean isServiceSecured()
                         throws RemoteException

Description copied from interface: SecuredService

If a security model is defined will return true.

Specified by:

isServiceSecured in interface SecuredService

Returns:

true if secured; false otherwise.

Throws:

RemoteException - communication-related exceptions that may occur during the execution of a remote method call.

isStartedWithinGSC

public boolean isStartedWithinGSC()
                           throws RemoteException

Description copied from interface: IJSpace

Returns true if the space started within a GSC.

Specified by:

isStartedWithinGSC in interface IJSpace

Throws:

RemoteException

getAdmin

public Object getAdmin()
                throws RemoteException

Description copied from interface: IJSpace

Returns the admin object to the remote part of this space.

 // get a list of classes and the number of entries of each class
 IRemoteJSpaceAdmin remoteAdmin =
 (IRemoteJSpaceAdmin)serverAdmin.getAdmin();
 Object classList[] = remoteAdmin.getRuntimeInfo().m_ClassNames.toArray();
 List numOFEntries = remoteAdmin.getRuntimeInfo().m_NumOFEntries;
 

Specified by:

getAdmin in interface Administrable

Specified by:

getAdmin in interface IJSpace

Returns:

the remoteAdmin object to the remote part of this space.

Throws:

RemoteException - if a communication error occurs

See Also:

• JoinAdmin

getPrivilegedAdmin

public Object getPrivilegedAdmin()
                          throws RemoteException

Get remote admin object for this space. No security checks are performed since this is for internal use only

Specified by:

getPrivilegedAdmin in interface ISpaceProxy

Throws:

RemoteException

See Also:

• IJSpace.getAdmin()

getNonClusteredProxy

public IJSpace getNonClusteredProxy()

Description copied from interface: IDirectSpaceProxy

Returns a proxy of the specified space. When the proxy is not part of a cluster, it returns itself as the only member.

Specified by:

getNonClusteredProxy in interface IDirectSpaceProxy

Returns:

IJSpace space proxy.

getClusteredProxy

public IJSpace getClusteredProxy()

Description copied from interface: IDirectSpaceProxy

Returns a clustered view of this proxy. When the proxy is not part of a cluster, it returns itself as the clustered view.

Specified by:

getClusteredProxy in interface IDirectSpaceProxy

Returns:

IJSpace space proxy.

getStubHandler

public IStubHandler getStubHandler()

Description copied from interface: IDirectSpaceProxy

Returns the StubHandler of this space.

Specified by:

getStubHandler in interface IDirectSpaceProxy

Returns:

StubHandler of this space.

getContainer

public IJSpaceContainer getContainer()

Description copied from interface: IDirectSpaceProxy

Returns the container proxy this space resides in.
The container holds information and attributes of neighboring spaces, and exposes API for creating and destroying of spaces.

Specified by:

getContainer in interface IDirectSpaceProxy

Returns:

Returns the container proxy.

shutdown

public void shutdown()
              throws RemoteException

Specified by:

shutdown in interface IDirectSpaceProxy

Throws:

RemoteException

getContainerConfig

public ContainerConfig getContainerConfig()
                                   throws RemoteException

Specified by:

getContainerConfig in interface IDirectSpaceProxy

Throws:

RemoteException

getContainerURL

public SpaceURL getContainerURL()
                         throws RemoteException

Specified by:

getContainerURL in interface IDirectSpaceProxy

Throws:

RemoteException

getFinderURL

public SpaceURL getFinderURL()

Description copied from interface: IJSpace

Returns the SpaceURL object which was used as the argument for SpaceFinder.find(SpaceURL) while looking for the space. If a client uses this SpaceURL when it calls to SpaceFinder.find(SpaceURL) it should be able to find that space. Notice: The SpaceURL returned when calling getURL() is different since in that case it returns the SpaceURL used to initialize the space (a java:// protocol to start an embedded space).

Specified by:

getFinderURL in interface IJSpace

Returns:

SpaceURL object which can be used to find the space proxy while calling SpaceFinder.find(SpaceURL)

setFinderURL

public void setFinderURL(SpaceURL _finderurl)

getURL

public SpaceURL getURL()

Description copied from interface: IJSpace

Returns the SpaceURL instance which was used to initialize the space.

Specified by:

getURL in interface IJSpace

isOptimisticLockingEnabled

public boolean isOptimisticLockingEnabled()

Description copied from interface: IJSpace

Returns status of Optimistic Lock protocol.

Specified by:

isOptimisticLockingEnabled in interface IJSpace

setOptimisticLocking

public void setOptimisticLocking(boolean enabled)

Description copied from interface: IJSpace

Enable/Disable Optimistic Lock protocol.

Specified by:

setOptimisticLocking in interface IJSpace

isFifo

public boolean isFifo()

Description copied from interface: IJSpace

Returns true if this proxy FIFO enabled, otherwise false.

Specified by:

isFifo in interface IJSpace

setFifo

public void setFifo(boolean enabled)

Description copied from interface: IJSpace

Sets FIFO mode for proxy.

Specified by:

setFifo in interface IJSpace

getReadModifiers

public int getReadModifiers()

Description copied from interface: IJSpace

Gets the proxy ReadModifiers.

Specified by:

getReadModifiers in interface IJSpace

setReadModifiers

public int setReadModifiers(int readModifiers)

Description copied from interface: IJSpace

Sets the read mode modifiers for proxy level.

Specified by:

setReadModifiers in interface IJSpace

getUpdateModifiers

public int getUpdateModifiers()

Description copied from interface: IJSpace

Gets the proxyUpdateModifiers.

Specified by:

getUpdateModifiers in interface IJSpace

setUpdateModifiers

public int setUpdateModifiers(int newModifiers)

Description copied from interface: IJSpace

Sets the update mode modifiers for proxy level.

Specified by:

setUpdateModifiers in interface IJSpace

isGatewayProxy

public boolean isGatewayProxy()

Specified by:

isGatewayProxy in interface IDirectSpaceProxy

setGatewayProxy

public void setGatewayProxy()

getVersion

public Object getVersion()

Specified by:

getVersion in interface SameProxyVersionProvider

createActionManager

protected AbstractSpaceProxyActionManager<SpaceProxyImpl> createActionManager()

Specified by:

createActionManager in class AbstractSpaceProxy

createNewOperationID

public OperationID createNewOperationID()

Description copied from interface: ISpaceProxy

Generate a unique operation ID

Specified by:

createNewOperationID in interface ISpaceProxy

Returns:

Unique operation ID

getClientID

public long getClientID()

Specified by:

getClientID in interface IDirectSpaceProxy

directClean

public void directClean()

Specified by:

directClean in interface IDirectSpaceProxy

directDropClass

public void directDropClass(String className)

login

public SecurityContext login(CredentialsProvider credentialsProvider)
                      throws RemoteException

Description copied from interface: SecuredService

Login to a secured service using the provided credentialsProvider.

Specified by:

login in interface SecuredService

Parameters:

credentialsProvider - provides credentials to be used for authentication.

Throws:

RemoteException - communication-related exceptions that may occur during the execution of a remote method call.

beforeSpaceAction

public Transaction beforeSpaceAction()

beforeSpaceAction

public void beforeSpaceAction(CommonProxyActionInfo action)

beforeSpaceAction

public Transaction beforeSpaceAction(Transaction txn)

equals

public boolean equals(Object obj)

overrides implementation of equals() method in AbstractSpaceProxy

Overrides:

equals in class AbstractDirectSpaceProxy

getRemoteMemberName

public String getRemoteMemberName()

Specified by:

getRemoteMemberName in interface IDirectSpaceProxy

getRemoteJSpace

public IRemoteSpace getRemoteJSpace()

Description copied from interface: IDirectSpaceProxy

Returns the reference to initial remote space

Specified by:

getRemoteJSpace in interface IDirectSpaceProxy

getSpaceImplIfEmbedded

public SpaceImpl getSpaceImplIfEmbedded()

Specified by:

getSpaceImplIfEmbedded in interface IDirectSpaceProxy

isClustered

public boolean isClustered()

Description copied from interface: ISpaceProxy

returns true if the proxy is Clustered

Specified by:

isClustered in interface ISpaceProxy

Returns:

true when the proxy is Clustered

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

close

public void close()

Description copied from interface: ISpaceProxy

Close the proxy and execute necessary cleanup logic.

Specified by:

close in interface ISpaceProxy

getMarshalPivot

public MarshalPivot getMarshalPivot()
                             throws RemoteException

Specified by:

getMarshalPivot in interface MarshalPivotProvider

Throws:

RemoteException

getTypeDescFromServer

public ITypeDesc getTypeDescFromServer(String typeName)

Specified by:

getTypeDescFromServer in interface IDirectSpaceProxy

registerTypeDescInServers

public void registerTypeDescInServers(ITypeDesc typeDesc)

Specified by:

registerTypeDescInServers in interface IDirectSpaceProxy

loadRemoteClass

public Class<?> loadRemoteClass(String className)
                         throws ClassNotFoundException

Description copied from interface: ISpaceProxy

Loads a remote class from the space, the class will be loaded locally into a corresponding LRMIClassLoader

Specified by:

loadRemoteClass in interface ISpaceProxy

Throws:

ClassNotFoundException

initWriteModifiers

public int initWriteModifiers(int modifiers)

Specified by:

initWriteModifiers in interface ISpaceProxy

getPartitionId

public int getPartitionId(Object routingValue)

Specified by:

getPartitionId in interface IDirectSpaceProxy

getFactory

public DirectSpaceProxyFactory getFactory()

Specified by:

getFactory in interface IDirectSpaceProxy

getSpaceClusterInfo

public SpaceClusterInfo getSpaceClusterInfo()

Specified by:

getSpaceClusterInfo in interface IDirectSpaceProxy

getProxyRouter

public SpaceProxyRouter getProxyRouter()

Specified by:

getProxyRouter in interface IDirectSpaceProxy

initProxyRouter

public void initProxyRouter(int partitionId)

updateProxyRouter

public void updateProxyRouter(SpaceProxyRouter oldRouter,
 ClusterTopology chunksMap)

Used in client side to update all proxy components with the new map

Parameters:

chunksMap -

afterClusterInfoChange

public void afterClusterInfoChange(SpaceClusterInfo clusterInfo)

Description copied from interface: IClusterInfoChangedListener

Updates server side components that holds SpaceClusterInfo instances when SpaceClusterInfo changes (i.e horizontal scale event)

Specified by:

afterClusterInfoChange in interface IClusterInfoChangedListener

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class AbstractDirectSpaceProxy

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class AbstractDirectSpaceProxy

Throws:

IOException

ClassNotFoundException

beforeExecute

public boolean beforeExecute(SpaceOperationRequest<?> spaceRequest,
 IRemoteSpace targetSpace,
 int partitionId,
 String clusterName,
 boolean isEmbedded)
                      throws RemoteException

Throws:

RemoteException

afterExecute

public static void afterExecute(SpaceOperationRequest<?> spaceRequest,
 IRemoteSpace targetSpace,
 int partitionId,
 boolean isRejected)

setQuiesceToken

public void setQuiesceToken(QuiesceToken token)

Specified by:

setQuiesceToken in interface IDirectSpaceProxy

prepareTemplate

public ISpaceQuery prepareTemplate(Object template)

Specified by:

prepareTemplate in interface IDirectSpaceProxy

demote

public void demote(long maxSuspendTime,
 TimeUnit timeUnit,
 CredentialsProvider credentialsProvider)
            throws DemoteFailedException,
RemoteException

Description copied from interface: IDirectSpaceProxy

Internal demote API for swapping from primary to backup Space.

Specified by:

demote in interface IDirectSpaceProxy

Parameters:

maxSuspendTime - maximum suspend time for the operation to complete

timeUnit - max suspend time unit to use

credentialsProvider - security credentials, or null, or EmptyCredentialsProvider

Throws:

DemoteFailedException

RemoteException

cloneProxy

public SpaceProxyImpl cloneProxy()

setMVCCGenerationsState

public void setMVCCGenerationsState(MVCCGenerationsState generationsState)

Specified by:

setMVCCGenerationsState in interface IDirectSpaceProxy