public class LRMISpaceImpl extends RemoteStub<IRemoteSpace> implements IRemoteSpace, IInternalRemoteJSpaceAdmin, Service
IRemoteJSpaceImpl interface.ABORTED, ACTIVE, COMMITTED, NOTCHANGED, PREPARED, VOTINGREPLICATION_STATUS_ACTIVE, REPLICATION_STATUS_DISABLED, REPLICATION_STATUS_DISCONNECTED| Constructor and Description |
|---|
LRMISpaceImpl() |
LRMISpaceImpl(IRemoteSpace directRefObj,
IRemoteSpace dynamicProxy)
constructor to initialize space stub
|
| Modifier and Type | Method and Description |
|---|---|
void |
abort(TransactionManager parm1,
long parm2)
Requests that the participant roll back any changes for the specified transaction and unlock
any resources locked by the transaction.
|
void |
abort(TransactionManager parm1,
Object parm2) |
SpaceMode |
addSpaceModeListener(ISpaceModeListener listener)
Adds a listener to be called back with
ISpaceModeListener mode changes. |
SuspendType |
addSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)
Adds a listener to be called back with
SuspendTypeChangedInternalListener suspend type changes. |
void |
cancel(String entryUID,
String classname,
int objectType) |
Exception[] |
cancelAll(String[] entryUIDs,
String[] classnames,
int[] objectTypes) |
ClusterTopology |
checkChunkMapGeneration(int clientGeneration) |
void |
commit(TransactionManager parm1,
long parm2)
Requests that the participant make all of its
PREPARED changes for the specified
transaction visible outside of the transaction and unlock any resources locked by the
transaction. |
void |
commit(TransactionManager parm1,
long parm2,
int numOfParticipants)
Requests that the participant make all of its
PREPARED changes for the specified
transaction visible outside of the transaction and unlock any resources locked by the
transaction. |
void |
commit(TransactionManager parm1,
Object parm2) |
void |
commit(TransactionManager parm1,
Object parm2,
int numOfParticipants) |
SpaceConnectResult |
connect(SpaceConnectRequest request) |
int |
countIncomingConnections() |
int |
countTransactions(int type,
int status) |
void |
demote(long maxSuspendTime,
TimeUnit unit,
SpaceContext sc)
Demote leadership and become a backup Space, in the specified operation timeout.
|
void |
disableLRMIMonitoring()
Disabled lrmi monitoring (gigaspaces internal remoting layer).
|
void |
disableStub()
disable remote.
|
void |
dropClass(String className,
SpaceContext sc)
Drop all Class entries and all its templates from the space.
|
void |
enableLRMIMonitoring()
Enables lrmi monitoring (gigaspaces internal remoting layer), this will cause the target to
start track lrmi invocations which can later be viewed by calling.
|
<T extends RemoteOperationResult> |
executeOperation(RemoteOperationRequest<T> request) |
<T extends RemoteOperationResult> |
executeOperationAsync(RemoteOperationRequest<T> request) |
void |
executeOperationOneway(RemoteOperationRequest<?> request) |
LRMIMonitoringDetails |
fetchLRMIMonitoringDetails()
Return lrmi (gigaspaces internal remoting layer) services monitoring details.
|
int |
flushRedoLogToStorage()
Flush redo-log packets from memory to underlying storage.
|
void |
forceMoveToPrimary()
Forcefully make this space to be primary
|
Object |
getAdmin()
Returns an object that implements whatever administration interfaces are appropriate for the
particular service.
|
ITypeDesc |
getClassDescriptor(String className)
Get the basic class information from the space directory.
|
ITypeDesc |
getClassDescriptor(String className,
boolean asVirtualType)
Get the basic class information from the space directory.
|
BasicTypeInfo |
getClassTypeInfo(String className)
Get the basic class information from the space directory.
|
byte[] |
getClusterConfigFile()
Returns a byte representation of the cluster configuration file.
|
ClusterPolicy |
getClusterPolicy()
Returns cluster policy.
|
SpaceConfig |
getConfig()
Returns
SpaceConfig of this space. |
List<ITransportConnection> |
getConnectionsInfo() |
long |
getCurrentTimestamp() |
JVMDetails |
getJVMDetails() |
JVMStatistics |
getJVMStatistics() |
Map<String,LocalCacheDetails> |
getLocalCacheDetails() |
Map<String,LocalViewDetails> |
getLocalViewDetails() |
List<UnderTxnLockedObject> |
getLockedObjects(Transaction txn)
getLockedObjects is called by the GUI.
|
String |
getName()
Returns the Space Name.
|
NIODetails |
getNIODetails()
Returns the transport configuration.
|
NIOStatistics |
getNIOStatistics()
Returns the transport statistics.
|
OSDetails |
getOSDetails() |
OSStatistics |
getOSStatistics() |
IQueryProcessor |
getQueryProcessor() |
String |
getReplicationDump() |
IReplicationConnectionProxy |
getReplicationRouterConnectionProxy() |
Object[] |
getReplicationStatus()
returns the replication member-status relation of all the replication groups.
|
RuntimeHolder |
getRuntimeHolder() |
SpaceRuntimeInfo |
getRuntimeInfo()
Returns
SpaceRuntimeInfo. |
SpaceRuntimeInfo |
getRuntimeInfo(String className)
Returns
SpaceRuntimeInfo for specific class name and its subclasses. |
Object |
getServiceProxy()
Returns a proxy object for this object.
|
SpaceHealthStatus |
getSpaceHealthStatus() |
SpaceInstanceRemoteClassLoaderInfo |
getSpaceInstanceRemoteClassLoaderInfo()
Return the info about the space classloader
|
SpaceMode |
getSpaceMode()
Get the current
SpaceMode which represents the current state of this participant in
the election process. |
Uuid |
getSpaceUuid()
returns the universal unique identifier of the remote space
|
int |
getState()
Returns the particular condition of this space.
|
DirectPersistencySyncListBatch |
getSynchronizationListBatch() |
List<TemplateInfo> |
getTemplatesInfo(String className)
Returns a list of pending templates.
|
TransactionInfo[] |
getTransactionsInfo(int type,
int status)
Returns all the transactions with the specific parameters.
|
String |
getUniqueID()
Generates and returns a unique id
|
String[] |
getZones() |
boolean |
isActive() |
boolean |
isActiveAndNotSuspended() |
Boolean |
isActiveAsync() |
boolean |
isEmbedded() |
boolean |
isStartedWithinGSC() |
Class<?> |
loadRemoteClass(String className) |
SecurityContext |
login(SecurityContext securityContext)
Login to a secured service using the provided
SecurityContext |
void |
ping()
Ping to space to see if alive.
|
int |
prepare(TransactionManager parm1,
long parm2)
Requests that the participant prepare itself to commit the transaction, and to vote on the
outcome of the transaction.
|
Object |
prepare(TransactionManager parm1,
long parm2,
boolean parm3) |
int |
prepare(TransactionManager parm1,
Object parm2) |
Object |
prepare(TransactionManager parm1,
Object parm2,
boolean parm3) |
int |
prepare(TransactionManager parm1,
Object parm2,
int numOfParticipants) |
Object |
prepare(TransactionManager parm1,
Object parm2,
int parm3,
boolean parm4) |
int |
prepareAndCommit(TransactionManager parm1,
long parm2)
A combination of
prepare and commit, which can be used by the
manager when there is just one participant left to prepare and all other participants (if
any) have responded with NOTCHANGED. |
int |
prepareAndCommit(TransactionManager parm1,
Object parm2) |
void |
quiesce(String description,
QuiesceToken token) |
void |
readExternal(ObjectInput in) |
void |
removeSpaceModeListener(ISpaceModeListener listener)
Removes this listener so that it no longer receives call backs of space mode changes.
|
void |
removeSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)
Removes this listener so that it no longer receives call backs of space suspend type changes.
|
long |
renew(String entryUID,
String classname,
int objectType,
long duration) |
Object[] |
renewAll(String[] entryUIDs,
String[] classnames,
int[] objectTypes,
long[] durations) |
void |
renewLease(TransactionManager mgr,
long id,
long time)
Notify the transaction participant about transaction lease renewal
|
void |
restart()
Restarts the space.
|
void |
runGc() |
void |
setClusterConfigFile(byte[] config)
set the cluster configuration according to the given byte representation of the configuration
file.
|
void |
snapshot(ITemplatePacket e) |
SpaceCopyStatus |
spaceCopy(IJSpace remoteSpace,
Object template,
boolean includeNotifyTemplates,
int chunkSize) |
SpaceCopyStatus |
spaceCopy(IRemoteSpace remoteProxy,
String remoteSpaceUrl,
String remoteSpaceName,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext spaceContext,
SpaceContext remoteSpaceContext)
Given ISpaceInternal of a remote space, Copy all entries/notify templates from the space.
|
SpaceCopyStatus |
spaceCopy(String remoteUrl,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize)
Given Url of a remote space, Copy all entries/notify templates from the space.
|
SpaceCopyStatus |
spaceCopy(String remoteUrl,
ITemplatePacket template,
boolean includeNotifyTemplates,
int chunkSize,
SpaceContext sc)
Given Url of a remote space, Copy all entries/notify templates from the space.
|
SpaceCopyStatus |
spaceCopy(String remoteUrl,
Object template,
boolean includeNotifyTemplates,
int chunkSize)
Igor.G 13/3/2005 ver 5.01.
|
void |
start()
Attempt to start this space.
|
void |
stop()
Attempt to stop this space.
|
void |
unquiesce() |
void |
updateClusterInfo()
trigger read of chunks map from zk and update clusterInfo
|
closeProxy, disable, enable, equals, getConnectionUrl, getDynamicProxy, getGeneratedTraffic, getProxy, getReceivedTraffic, getRemoteHostAddress, getRemoteHostName, getRemoteNetworkAddress, getRemoteProcessId, getServicePlatformLogicalVersion, getStubId, hashCode, init, isClosed, isCollocated, isCollocatedStub, isDirect, isRemote, isStub, overrideMethodsMetadata, toString, writeExternalclone, finalize, getClass, notify, notifyAll, wait, wait, waitenabledSmartExternalizableWithReferencepublic LRMISpaceImpl()
public LRMISpaceImpl(IRemoteSpace directRefObj, IRemoteSpace dynamicProxy)
public boolean isEmbedded()
isEmbedded in interface IRemoteSpacepublic Object[] getReplicationStatus() throws RemoteException
IRemoteJSpaceAdmin
Usage:
Object[] replStatus = spaceAdmin.getReplicationStatus();
String[] peers = (String[])replStatus[0];
int[] status = (int[])replStatus[1];
getReplicationStatus in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic boolean isStartedWithinGSC()
throws RemoteException
isStartedWithinGSC in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic RuntimeHolder getRuntimeHolder() throws RemoteException
getRuntimeHolder in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic void snapshot(ITemplatePacket e) throws UnusableEntryException, RemoteException
snapshot in interface IRemoteSpaceUnusableEntryExceptionRemoteExceptionpublic void cancel(String entryUID, String classname, int objectType) throws UnknownLeaseException, RemoteException
cancel in interface IRemoteSpaceUnknownLeaseExceptionRemoteExceptionpublic long renew(String entryUID, String classname, int objectType, long duration) throws LeaseDeniedException, UnknownLeaseException, RemoteException
renew in interface IRemoteSpaceLeaseDeniedExceptionUnknownLeaseExceptionRemoteExceptionpublic Exception[] cancelAll(String[] entryUIDs, String[] classnames, int[] objectTypes) throws RemoteException
cancelAll in interface IRemoteSpaceRemoteExceptionpublic Object[] renewAll(String[] entryUIDs, String[] classnames, int[] objectTypes, long[] durations) throws RemoteException
renewAll in interface IRemoteSpaceRemoteExceptionpublic void restart()
throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
try
{
spaceAdmin.restart();
}
catch( java.rmi.RemoteException ex )
{
System.err.println("Failed to restart space: " + ((IJSpace)space).getName());
System.err.println("Exception: " + ex);
}
restart in interface IInternalRemoteJSpaceAdminRemoteException - Failed to restart space.public SuspendType addSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)
IInternalRemoteJSpaceAdminSuspendTypeChangedInternalListener suspend type changes.addSpaceSuspendTypeListener in interface IInternalRemoteJSpaceAdminlistener - - SuspendTypeChangedInternalListener that will receive notification when a space suspend type changes (SuspendType)public void removeSpaceSuspendTypeListener(SuspendTypeChangedInternalListener listener)
IInternalRemoteJSpaceAdminremoveSpaceSuspendTypeListener in interface IInternalRemoteJSpaceAdminlistener - - SuspendTypeChangedInternalListener that will stop receiving notification when a space suspend type changes (SuspendType)public SpaceInstanceRemoteClassLoaderInfo getSpaceInstanceRemoteClassLoaderInfo() throws RemoteException
IRemoteJSpaceAdmingetSpaceInstanceRemoteClassLoaderInfo in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic void ping()
throws RemoteException
IRemoteJSpaceAdminUsage:
try
{
spaceAdmin.ping();
}
catch (RemoteException re)
{
System.err.println("Space not accessible");
}ping in interface IRemoteSpaceping in interface IRemoteJSpaceAdminRemoteException - if a communication error occursIRemoteJSpaceAdmin.getState()public DirectPersistencySyncListBatch getSynchronizationListBatch() throws RemoteException
getSynchronizationListBatch in interface IRemoteSpaceRemoteExceptionpublic void quiesce(String description, QuiesceToken token) throws RemoteException
quiesce in interface IRemoteSpaceRemoteExceptionpublic void unquiesce()
throws RemoteException
unquiesce in interface IRemoteSpaceRemoteExceptionpublic String getName() throws RemoteException
IRemoteJSpaceAdmin
Usage:
spaceAdmin.getName()
getName in interface IRemoteSpacegetName in interface IRemoteJSpaceAdminRemoteException - Failed to get namepublic SpaceRuntimeInfo getRuntimeInfo() throws RemoteException
IRemoteJSpaceAdminSpaceRuntimeInfo.
Usage:
SpaceRuntimeInfo runtime = spaceAdmin.getRuntimeInfo();
List classNames = runtime.m_ClassNames;
List numOfEntries = runtime.m_NumOFEntries;
getRuntimeInfo in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic SpaceRuntimeInfo getRuntimeInfo(String className) throws RemoteException
IRemoteJSpaceAdminSpaceRuntimeInfo for specific class name and its subclasses.
Usage:
String className = ExampleObject.class.getName();
SpaceRuntimeInfo runtime = spaceAdmin.getRuntimeInfo(className);
List classNames = runtime.m_ClassNames;
List numOfEntries = runtime.m_NumOFEntries;
getRuntimeInfo in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic SpaceConfig getConfig() throws RemoteException
IRemoteJSpaceAdminSpaceConfig of this space.
Usage:
SpaceConfig config = spaceAdmin.getConfig();
if (config != null)
boolean isClustered = config.m_isClustered;
getConfig in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic void disableStub()
throws RemoteException
IInternalRemoteJSpaceAdmindisableStub in interface IInternalRemoteJSpaceAdminRemoteException - if a communication error occurspublic ITypeDesc getClassDescriptor(String className) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
com.j_spaces.core.client.BasicTypeInfo classInfo
= spaceAdmin.getClassTypeInfo( className );
String[] fieldNames = classInfo.m_FieldsNames;
String[] fieldTypes = classInfo.m_FieldsTypes;
getClassDescriptor in interface IInternalRemoteJSpaceAdminclassName - - The name of the class to retrieve the information from.RemoteException - if a communication error occurspublic ITypeDesc getClassDescriptor(String className, boolean asVirtualType) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
com.j_spaces.core.client.BasicTypeInfo classInfo
= spaceAdmin.getClassTypeInfo( className );
String[] fieldNames = classInfo.m_FieldsNames;
String[] fieldTypes = classInfo.m_FieldsTypes;
getClassDescriptor in interface IInternalRemoteJSpaceAdminclassName - - The name of the class to retrieve the information from.RemoteException - if a communication error occurspublic BasicTypeInfo getClassTypeInfo(String className) throws RemoteException
IRemoteJSpaceAdmin
Usage:
com.j_spaces.core.client.BasicTypeInfo classInfo
= spaceAdmin.getClassTypeInfo( className );
String[] fieldNames = classInfo.m_FieldsNames;
String[] fieldTypes = classInfo.m_FieldsTypes;
getClassTypeInfo in interface IRemoteJSpaceAdminclassName - - The name of the class to retrieve the information from.RemoteException - if a communication error occurspublic void abort(TransactionManager parm1, Object parm2) throws UnknownTransactionException, RemoteException
abort in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic void abort(TransactionManager parm1, long parm2) throws UnknownTransactionException, RemoteException
TransactionParticipantabort in interface TransactionParticipantparm1 - the manager of the transactionparm2 - the transaction IDUnknownTransactionException - if the transaction is unknown to the transaction manager,
either because the transaction ID is incorrect or because
the transaction is complete and its state has been
discarded by the manager.RemoteException - if there is a communication errorpublic void commit(TransactionManager parm1, Object parm2) throws UnknownTransactionException, RemoteException
commit in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic void commit(TransactionManager parm1, long parm2) throws UnknownTransactionException, RemoteException
TransactionParticipantPREPARED changes for the specified
transaction visible outside of the transaction and unlock any resources locked by the
transaction. All state associated with the transaction can then be discarded by the
participant.commit in interface TransactionParticipantparm1 - the manager of the transactionparm2 - the transaction IDUnknownTransactionException - if the transaction is unknown to the transaction manager,
either because the transaction ID is incorrect or because
the transaction is complete and its state has been
discarded by the manager.RemoteException - if there is a communication errorpublic void commit(TransactionManager parm1, long parm2, int numOfParticipants) throws UnknownTransactionException, RemoteException
TransactionParticipantPREPARED changes for the specified
transaction visible outside of the transaction and unlock any resources locked by the
transaction. All state associated with the transaction can then be discarded by the
participant.commit in interface TransactionParticipantparm1 - the manager of the transactionparm2 - the transaction IDnumOfParticipants - the total number of transaction participants this is needed only in
commit , since prepareAndCommit is called for single participantUnknownTransactionException - if the transaction is unknown to the transaction manager,
either because the transaction ID is incorrect or because
the transaction is complete and its state has been
discarded by the manager.RemoteException - if there is a communication errorpublic void commit(TransactionManager parm1, Object parm2, int numOfParticipants) throws UnknownTransactionException, RemoteException
commit in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic int prepare(TransactionManager parm1, Object parm2) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic int prepare(TransactionManager parm1, long parm2) throws UnknownTransactionException, RemoteException
TransactionParticipantPREPARED,
indicating that it is prepared; ABORT, indicating that it will abort, or
NOTCHANGED, indicating that it did not have any state changed by the transaction
(i.e., it was read-only). If the response is PREPARED, the participant must wait
until it receives a commit or abort call from the transaction manager; it may query the
transaction manager if needed as to the state of the transaction. If the response is
ABORT, the participant should roll its state back to undo any changes that
occurred due to operations performed under the transaction; it can then discard any
information about the transaction. If the response is NOTCHANGED, the
participant can immediately discard any knowledge of the transaction.prepare in interface TransactionParticipantparm1 - the manager of the transactionparm2 - the transaction IDint representing this participant's stateUnknownTransactionException - if the transaction is unknown to the transaction manager,
either because the transaction ID is incorrect or because
the transaction is complete and its state has been
discarded by the manager.RemoteException - if there is a communication errorpublic int prepare(TransactionManager parm1, Object parm2, int numOfParticipants) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic int prepareAndCommit(TransactionManager parm1, Object parm2) throws UnknownTransactionException, RemoteException
prepareAndCommit in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic Object prepare(TransactionManager parm1, long parm2, boolean parm3) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic Object prepare(TransactionManager parm1, Object parm2, boolean parm3) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic Object prepare(TransactionManager parm1, Object parm2, int parm3, boolean parm4) throws UnknownTransactionException, RemoteException
prepare in interface IRemoteSpaceUnknownTransactionExceptionRemoteExceptionpublic int prepareAndCommit(TransactionManager parm1, long parm2) throws UnknownTransactionException, RemoteException
TransactionParticipantprepare and commit, which can be used by the
manager when there is just one participant left to prepare and all other participants (if
any) have responded with NOTCHANGED. The participant's implementation of this
method must be equivalent to:
public int prepareAndCommit(TransactionManager mgr, long id)
throws UnknownTransactionException, RemoteException
{
int result = prepare(mgr, id);
if (result == PREPARED) {
commit(mgr, id);
result = COMMITTED;
}
return result;
}
prepareAndCommit in interface TransactionParticipantparm1 - the manager of the transactionparm2 - the transaction IDint representing its stateUnknownTransactionException - if the transaction is unknown to the transaction manager,
either because the transaction ID is incorrect or because
the transaction is complete and its state has been
discarded by the manager.RemoteException - if there is a communication errorTransactionParticipant.prepare(net.jini.core.transaction.server.TransactionManager, long),
TransactionParticipant.commit(net.jini.core.transaction.server.TransactionManager, long)public void dropClass(String className, SpaceContext sc) throws RemoteException, DropClassException
IRemoteJSpaceAdmin
Usage:
spaceAdmin.dropClass( className );
dropClass in interface IRemoteJSpaceAdminclassName - name of class to delete.RemoteException - if a communication error occursDropClassException - Failed to drop desired class.public ClusterPolicy getClusterPolicy() throws RemoteException
getClusterPolicy in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic Object getAdmin() throws RemoteException
AdministrablegetAdmin in interface AdministrableRemoteExceptionJoinAdminpublic String getUniqueID() throws RemoteException
IRemoteSpacegetUniqueID in interface IRemoteSpaceRemoteExceptionpublic Uuid getSpaceUuid() throws RemoteException
IRemoteSpacegetSpaceUuid in interface IRemoteSpaceRemoteExceptionpublic TransactionInfo[] getTransactionsInfo(int type, int status) throws RemoteException
IInternalRemoteJSpaceAdmingetTransactionsInfo in interface IInternalRemoteJSpaceAdmintype - TransactionInfo.Types.LOCAL, TransactionInfo.Types.JINI or
TransactionInfo.Types.XA. Use TransactionInfo.Types.All for all types;status - can be one of the status defined in TransactionConstantsRemoteException - if a communication error occurspublic int countTransactions(int type,
int status)
throws RemoteException
countTransactions in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic List<TemplateInfo> getTemplatesInfo(String className) throws RemoteException
IInternalRemoteJSpaceAdmingetTemplatesInfo in interface IInternalRemoteJSpaceAdminclassName - name of the class to searchRemoteExceptionpublic List<ITransportConnection> getConnectionsInfo() throws RemoteException
getConnectionsInfo in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic int countIncomingConnections()
throws RemoteException
countIncomingConnections in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic List<UnderTxnLockedObject> getLockedObjects(Transaction txn) throws RemoteException
IInternalRemoteJSpaceAdmingetLockedObjects in interface IInternalRemoteJSpaceAdmintxn - - the Transaction that locks the Objects.RemoteExceptionpublic SpaceMode getSpaceMode() throws RemoteException
IInternalRemoteJSpaceAdminSpaceMode which represents the current state of this participant in
the election process. In case of a non-clustered participant, where no election process
takes place, the return value is always SpaceMode.PRIMARY.
getSpaceMode in interface IInternalRemoteJSpaceAdminSpaceMode of the space.RemoteException - if an exception occurred executing this remote method.public SpaceMode addSpaceModeListener(ISpaceModeListener listener) throws RemoteException
IInternalRemoteJSpaceAdminISpaceModeListener mode changes. The change (
SpaceMode ) represents the result of an election process of this
participant space. The returned value represents the current state of this participant in the
election process. In case of a non-clustered participant, the return value is always
SpaceMode.PRIMARY. Hence, no election process will take place and the listener will
not be called.
addSpaceModeListener in interface IInternalRemoteJSpaceAdminlistener - a listener to be called back on space mode changes.SpaceMode of the space.RemoteException - if an exception occurred executing this remote method.ISpaceModeListener,
SpaceModepublic void removeSpaceModeListener(ISpaceModeListener listener) throws RemoteException
IInternalRemoteJSpaceAdminremoveSpaceModeListener in interface IInternalRemoteJSpaceAdminlistener - a listener to be removed.RemoteException - if an exception occurred executing this remote method.IInternalRemoteJSpaceAdmin.addSpaceModeListener(ISpaceModeListener)public void start()
throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
spaceAdmin.start();
start in interface IInternalRemoteJSpaceAdminRemoteException - - Failed to start space.SpaceAlreadyStartedException - - The space is already startedpublic void stop()
throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
spaceAdmin.stop();
stop in interface IInternalRemoteJSpaceAdminRemoteException - - Failed to stop space.SpaceAlreadyStoppedException - - The space is already stoppedpublic int getState()
throws RemoteException
IRemoteJSpaceAdmingetState in interface IRemoteJSpaceAdminRemoteException - if a communication error occursISpaceStatepublic NIODetails getNIODetails() throws RemoteException
NIOInfoProvidergetNIODetails in interface NIOInfoProviderRemoteExceptionpublic NIOStatistics getNIOStatistics() throws RemoteException
NIOInfoProvidergetNIOStatistics in interface NIOInfoProviderRemoteExceptionpublic void enableLRMIMonitoring()
throws RemoteException
NIOInfoProviderNIOInfoProvider.fetchLRMIMonitoringDetails()enableLRMIMonitoring in interface NIOInfoProviderRemoteExceptionpublic void disableLRMIMonitoring()
throws RemoteException
NIOInfoProviderNIOInfoProvider.enableLRMIMonitoring()disableLRMIMonitoring in interface NIOInfoProviderRemoteExceptionpublic LRMIMonitoringDetails fetchLRMIMonitoringDetails() throws RemoteException
NIOInfoProviderNIOInfoProvider.enableLRMIMonitoring()fetchLRMIMonitoringDetails in interface NIOInfoProviderRemoteExceptionpublic long getCurrentTimestamp()
throws RemoteException
getCurrentTimestamp in interface OSInfoProviderRemoteExceptionpublic OSDetails getOSDetails() throws RemoteException
getOSDetails in interface OSInfoProviderRemoteExceptionpublic OSStatistics getOSStatistics() throws RemoteException
getOSStatistics in interface OSInfoProviderRemoteExceptionpublic JVMDetails getJVMDetails() throws RemoteException
getJVMDetails in interface JVMInfoProviderRemoteExceptionpublic JVMStatistics getJVMStatistics() throws RemoteException
getJVMStatistics in interface JVMInfoProviderRemoteExceptionpublic void runGc()
throws RemoteException
runGc in interface JVMInfoProviderRemoteExceptionpublic String[] getZones() throws RemoteException
getZones in interface GridZoneProviderRemoteExceptionpublic byte[] getClusterConfigFile()
throws RemoteException
IInternalRemoteJSpaceAdmingetClusterConfigFile in interface IInternalRemoteJSpaceAdminRemoteException - if a communication error occurspublic void setClusterConfigFile(byte[] config)
throws RemoteException
IInternalRemoteJSpaceAdminsetClusterConfigFile in interface IInternalRemoteJSpaceAdminconfig - byte representation of the configuration fileRemoteException - if a communication error occurspublic SpaceCopyStatus spaceCopy(String remoteUrl, Object template, boolean includeNotifyTemplates, int chunkSize) throws RemoteException
spaceCopy in interface IRemoteJSpaceAdminremoteUrl - url of remote space to copy fromtemplate - Entry template or null.includeNotifyTemplates - - if true ALL notify templates will be copied toochunkSize - Chunk size (batch) for this copy operation.RemoteException - if a communication error occurspublic SpaceCopyStatus spaceCopy(String remoteUrl, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( sourceSpaceURL, template, false );
System.out.println("Copy-Status: " + copyStatus );
spaceCopy in interface IInternalRemoteJSpaceAdminremoteUrl - url of remote space to copy fromtemplate - EntryPacket template or null.includeNotifyTemplates - - if true ALL notify templates will be copied toochunkSize - Chunk size (batch) for this copy operation.RemoteException - if a communication error occurspublic SpaceCopyStatus spaceCopy(String remoteUrl, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize, SpaceContext sc) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( sourceSpaceURL, template, false );
System.out.println("Copy-Status: " + copyStatus );
spaceCopy in interface IInternalRemoteJSpaceAdminremoteUrl - url of remote space to copy fromtemplate - EntryPacket template or null.includeNotifyTemplates - - if true ALL notify templates will be copied toochunkSize - Chunk size (batch) for this copy operation.sc - SpaceContext for security check in the server side.RemoteException - if a communication error occurspublic SpaceCopyStatus spaceCopy(IJSpace remoteSpace, Object template, boolean includeNotifyTemplates, int chunkSize) throws RemoteException
spaceCopy in interface IRemoteJSpaceAdminRemoteExceptionpublic SpaceCopyStatus spaceCopy(IRemoteSpace remoteProxy, String remoteSpaceUrl, String remoteSpaceName, ITemplatePacket template, boolean includeNotifyTemplates, int chunkSize, SpaceContext spaceContext, SpaceContext remoteSpaceContext) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( remoteProxy, remoteURL, remoteName,
template, false 1000, sc);
System.out.println("Copy-Status: " + copyStatus );
spaceCopy in interface IInternalRemoteJSpaceAdminremoteProxy - ISpaceInternal, a proxy to the remote space to copy fromremoteSpaceUrl - the remote space url.remoteSpaceName - the remote space name.template - A template for identified entries that should be copied.includeNotifyTemplates - - if true ALL notify templates will be copied toochunkSize - Chunk size (batch) for this copy operation.spaceContext - SpaceContext for security check in the server side.remoteSpaceContext - remoteSpaceContext for security check in the server side.RemoteException - if a communication error occurspublic IQueryProcessor getQueryProcessor() throws RemoteException
getQueryProcessor in interface IRemoteSpaceRemoteExceptionpublic void renewLease(TransactionManager mgr, long id, long time) throws LeaseDeniedException, UnknownLeaseException, RemoteException
TransactionParticipantrenewLease in interface TransactionParticipantLeaseDeniedExceptionUnknownLeaseExceptionRemoteExceptionpublic SpaceHealthStatus getSpaceHealthStatus() throws RemoteException
getSpaceHealthStatus in interface IRemoteSpaceRemoteExceptionpublic SecurityContext login(SecurityContext securityContext) throws RemoteException
RemoteSecuredServiceSecurityContextlogin in interface RemoteSecuredServicesecurityContext - security context to be used for authentication.RemoteException - communication-related exceptions that may occur during the execution
of a remote method call.public Object getServiceProxy() throws RemoteException
ServiceProxyAccessornull.getServiceProxy in interface ServiceProxyAccessorRemoteExceptionpublic SpaceConnectResult connect(SpaceConnectRequest request) throws RemoteException
connect in interface IRemoteSpaceRemoteExceptionpublic void forceMoveToPrimary()
throws RemoteException
IInternalRemoteJSpaceAdminforceMoveToPrimary in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic IReplicationConnectionProxy getReplicationRouterConnectionProxy() throws RemoteException
getReplicationRouterConnectionProxy in interface IRemoteSpaceRemoteExceptionpublic String getReplicationDump() throws RemoteException
getReplicationDump in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic int flushRedoLogToStorage()
throws RemoteException
IInternalRemoteJSpaceAdminflushRedoLogToStorage in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic Class<?> loadRemoteClass(String className) throws RemoteException, ClassNotFoundException
loadRemoteClass in interface IRemoteSpaceRemoteExceptionClassNotFoundExceptionpublic <T extends RemoteOperationResult> T executeOperation(RemoteOperationRequest<T> request) throws RemoteException
executeOperation in interface RemoteOperationsExecutorRemoteExceptionpublic <T extends RemoteOperationResult> T executeOperationAsync(RemoteOperationRequest<T> request) throws RemoteException
executeOperationAsync in interface RemoteOperationsExecutorRemoteExceptionpublic void executeOperationOneway(RemoteOperationRequest<?> request) throws RemoteException
executeOperationOneway in interface RemoteOperationsExecutorRemoteExceptionpublic boolean isActive()
throws RemoteException
isActive in interface RemoteOperationsExecutorRemoteExceptionpublic boolean isActiveAndNotSuspended()
throws RemoteException
isActiveAndNotSuspended in interface RemoteOperationsExecutorRemoteExceptionpublic ClusterTopology checkChunkMapGeneration(int clientGeneration)
checkChunkMapGeneration in interface RemoteOperationsExecutorpublic Boolean isActiveAsync() throws RemoteException
isActiveAsync in interface RemoteOperationsExecutorRemoteExceptionpublic Map<String,LocalCacheDetails> getLocalCacheDetails() throws RemoteException
getLocalCacheDetails in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic Map<String,LocalViewDetails> getLocalViewDetails() throws RemoteException
getLocalViewDetails in interface IInternalRemoteJSpaceAdminRemoteExceptionpublic void demote(long maxSuspendTime,
TimeUnit unit,
SpaceContext sc)
throws DemoteFailedException,
RemoteException
IRemoteSpacedemote in interface IRemoteSpacemaxSuspendTime - The maximum time allowed to be in suspended state, after which the operation is aborted.unit - The unit of time for the maxSuspendTime parameter.sc - The SpaceContext for security check in the server side.DemoteFailedExceptionRemoteExceptionpublic void updateClusterInfo()
throws RemoteException
IRemoteJSpaceAdminupdateClusterInfo in interface IRemoteJSpaceAdminRemoteException - if a communication error occurspublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal in interface ExternalizablereadExternal in class RemoteStub<IRemoteSpace>IOExceptionClassNotFoundExceptionCopyright © GigaSpaces.