public class JSpaceAdminProxy extends ServiceAdminProxy implements IInternalRemoteJSpaceAdmin, StatisticsAdmin
adminImpl, uuid
REPLICATION_STATUS_ACTIVE, REPLICATION_STATUS_DISABLED, REPLICATION_STATUS_DISCONNECTED
Constructor and Description |
---|
JSpaceAdminProxy(ServiceAdmin admin,
Uuid uuid) |
Modifier and Type | Method and Description |
---|---|
SpaceMode |
addSpaceModeListener(ISpaceModeListener listener)
Adds a listener to be called back with
ISpaceModeListener mode changes. |
int |
countIncomingConnections() |
int |
countTransactions(int type,
int status) |
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.
|
LRMIMonitoringDetails |
fetchLRMIMonitoringDetails()
Return lrmi (gigaspaces internal remoting layer) services monitoring details.
|
void |
forceMoveToPrimary()
Forcefully make this space to be primary
|
ITypeDesc |
getClassDescriptor(String className)
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()
Return the present ClusterPolicy objects.
|
SpaceConfig |
getConfig()
Returns
SpaceConfig of this space. |
List<ITransportConnection> |
getConnectionsInfo() |
long |
getCurrentTimestamp() |
StatisticsHolder |
getHolder() |
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() |
String |
getReplicationDump() |
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. |
IJSpace |
getSpace()
return the defined spaceProxy for this spaceAdmin,
null if setSpace hasn't never
invoked |
SpaceMode |
getSpaceMode()
Get the current
SpaceMode which represents the current state of this participant in
the election process. |
int |
getState()
Returns the particular condition of this space.
|
Map<Integer,StatisticsContext> |
getStatistics()
Returns statistics repository that contains a map of operation codes to
StatisticsContext objects for all filter
operation codes. |
StatisticsContext |
getStatistics(int operationCode)
Returns a
StatisticsContext for specific
filter operation code. |
Map<Integer,StatisticsContext> |
getStatistics(Integer[] operationCodes)
Returns statistics repository that contains a map of operation codes to
StatisticsContext objects for passed specific
filter operation codes. |
long |
getStatisticsSamplingRate()
Checks statistics sampling rate.
|
String[] |
getStatisticsStringArray()
Returns a string array contains statistics values for each operation.
|
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[] |
getZones() |
boolean |
isStartedWithinGSC() |
boolean |
isStatisticsAvailable()
Checks if space statistics is available.
|
void |
ping()
Ping to space to see if alive.
|
void |
removeSpaceModeListener(ISpaceModeListener listener)
Removes this listener so that it no longer receives call backs of space mode changes.
|
void |
restart()
IRemoteJSpaceAdmin interface
|
void |
runGc() |
void |
setClusterConfigFile(byte[] config)
set the cluster configuration according to the given byte representation of the configuration
file.
|
void |
setSpace(IJSpace space)
set space proxy for this Admin proxy, useally calls by IJSpace.getAdmin() method
|
void |
setStatisticsSamplingRate(long rate)
Set statistics sampling rate.
|
SpaceCopyStatus |
spaceCopy(IJSpace remoteProxy,
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 templPacket,
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)
Given Url of a remote space, Copy all entries/notify templates from the space.
|
void |
start()
Attempt to start this space.
|
void |
stop()
Attempt to stop this space.
|
addLookupAttributes, addLookupGroups, addLookupLocators, destroy, equals, getInstance, getLookupAttributes, getLookupGroups, getLookupLocators, getReferentUuid, hashCode, modifyLookupAttributes, removeLookupGroups, removeLookupLocators, setLookupGroups, setLookupLocators
public JSpaceAdminProxy(ServiceAdmin admin, Uuid uuid)
public void setSpace(IJSpace space)
public IJSpace getSpace()
null
if setSpace hasn't never
invokedpublic void restart() throws RemoteException
restart
in interface IInternalRemoteJSpaceAdmin
RemoteException
- Failed to restart space.public String getName() throws RemoteException
IRemoteJSpaceAdmin
Usage:
spaceAdmin.getName()
getName
in interface IRemoteJSpaceAdmin
RemoteException
- Failed to get namepublic SpaceRuntimeInfo getRuntimeInfo() throws RemoteException
IRemoteJSpaceAdmin
SpaceRuntimeInfo
.
Usage:
SpaceRuntimeInfo runtime = spaceAdmin.getRuntimeInfo();
List classNames = runtime.m_ClassNames;
List numOfEntries = runtime.m_NumOFEntries;
getRuntimeInfo
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic SpaceRuntimeInfo getRuntimeInfo(String className) throws RemoteException
IRemoteJSpaceAdmin
SpaceRuntimeInfo
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 IRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic SpaceConfig getConfig() throws RemoteException
IRemoteJSpaceAdmin
SpaceConfig
of this space.
Usage:
SpaceConfig config = spaceAdmin.getConfig();
if (config != null)
boolean isClustered = config.m_isClustered;
getConfig
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic void ping() throws RemoteException
IRemoteJSpaceAdmin
Usage:
try
{
spaceAdmin.ping();
}
catch (RemoteException re)
{
System.err.println("Space not accessible");
}
ping
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occursIRemoteJSpaceAdmin.getState()
public void disableStub() throws RemoteException
IInternalRemoteJSpaceAdmin
disableStub
in interface IInternalRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic Object[] getReplicationStatus() throws RemoteException
IRemoteJSpaceAdmin
Usage:
Object[] replStatus = spaceAdmin.getReplicationStatus();
String[] peers = (String[])replStatus[0];
int[] status = (int[])replStatus[1];
getReplicationStatus
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic RuntimeHolder getRuntimeHolder() throws RemoteException
getRuntimeHolder
in interface IInternalRemoteJSpaceAdmin
RemoteException
public boolean isStartedWithinGSC() throws RemoteException
isStartedWithinGSC
in interface IInternalRemoteJSpaceAdmin
RemoteException
public 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 IInternalRemoteJSpaceAdmin
className
- - 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 IRemoteJSpaceAdmin
className
- - The name of the class to retrieve the information from.RemoteException
- if a communication error occurspublic ClusterPolicy getClusterPolicy() throws RemoteException
IRemoteJSpaceAdmin
getClusterPolicy
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic void dropClass(String className, SpaceContext sc) throws RemoteException, DropClassException
IRemoteJSpaceAdmin
Usage:
spaceAdmin.dropClass( className );
dropClass
in interface IRemoteJSpaceAdmin
className
- name of class to delete.RemoteException
- if a communication error occursDropClassException
- Failed to drop desired class.public void start() throws RemoteException, SpaceAlreadyStartedException
IInternalRemoteJSpaceAdmin
Usage:
spaceAdmin.start();
start
in interface IInternalRemoteJSpaceAdmin
RemoteException
- - Failed to start space.SpaceAlreadyStartedException
- - The space is already startedpublic void stop() throws RemoteException, SpaceAlreadyStoppedException
IInternalRemoteJSpaceAdmin
Usage:
spaceAdmin.stop();
stop
in interface IInternalRemoteJSpaceAdmin
RemoteException
- - Failed to stop space.SpaceAlreadyStoppedException
- - The space is already stoppedpublic TransactionInfo[] getTransactionsInfo(int type, int status) throws RemoteException
IInternalRemoteJSpaceAdmin
getTransactionsInfo
in interface IInternalRemoteJSpaceAdmin
type
- 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 TransactionConstants
RemoteException
- if a communication error occursIRemoteJSpaceAdmin
public int countTransactions(int type, int status) throws RemoteException
countTransactions
in interface IInternalRemoteJSpaceAdmin
RemoteException
public List<TemplateInfo> getTemplatesInfo(String className) throws RemoteException
IInternalRemoteJSpaceAdmin
getTemplatesInfo
in interface IInternalRemoteJSpaceAdmin
className
- name of the class to searchRemoteException
IInternalRemoteJSpaceAdmin.getTemplatesInfo(java.lang.String)
public List<ITransportConnection> getConnectionsInfo() throws RemoteException
getConnectionsInfo
in interface IInternalRemoteJSpaceAdmin
RemoteException
public int countIncomingConnections() throws RemoteException
countIncomingConnections
in interface IInternalRemoteJSpaceAdmin
RemoteException
public List<UnderTxnLockedObject> getLockedObjects(Transaction txn) throws RemoteException
IInternalRemoteJSpaceAdmin
getLockedObjects
in interface IInternalRemoteJSpaceAdmin
txn
- - the Transaction that locks the Objects.RemoteException
public int getState() throws RemoteException
IRemoteJSpaceAdmin
getState
in interface IRemoteJSpaceAdmin
RemoteException
- if a communication error occursISpaceState
public boolean isStatisticsAvailable() throws RemoteException
StatisticsAdmin
isStatisticsAvailable
in interface StatisticsAdmin
true
if space statistics is availableRemoteException
- if a communication error occurspublic String[] getStatisticsStringArray() throws RemoteException
StatisticsAdmin
getStatisticsStringArray
in interface StatisticsAdmin
StatisticsNotAvailable
- when space statistics are not availableRemoteException
- if a communication error occurspublic void setStatisticsSamplingRate(long rate) throws RemoteException
StatisticsAdmin
setStatisticsSamplingRate
in interface StatisticsAdmin
rate
- the rate to sample the space for statisticsStatisticsNotAvailable
- when space statistics are not availableRemoteException
- if a communication error occurspublic long getStatisticsSamplingRate() throws RemoteException
StatisticsAdmin
getStatisticsSamplingRate
in interface StatisticsAdmin
StatisticsNotAvailable
- when space statistics are not availableRemoteException
- if a communication error occurspublic StatisticsContext getStatistics(int operationCode) throws RemoteException
StatisticsAdmin
StatisticsContext
for specific
filter operation code.getStatistics
in interface StatisticsAdmin
operationCode
- filter operation code defined in FilterOperationCodes
StatisticsNotAvailable
- when space statistics are not availableRemoteException
- if a communication error occursFilterOperationCodes
public StatisticsHolder getHolder() throws RemoteException
getHolder
in interface StatisticsAdmin
RemoteException
public Map<Integer,StatisticsContext> getStatistics(Integer[] operationCodes) throws RemoteException
StatisticsAdmin
StatisticsContext
objects for passed specific
filter operation codes.getStatistics
in interface StatisticsAdmin
operationCodes
- filter array of operation codes defined in FilterOperationCodes
StatisticsContext
StatisticsNotAvailable
- when space statistics are not availableRemoteException
- if a communication error occurspublic Map<Integer,StatisticsContext> getStatistics() throws RemoteException
StatisticsAdmin
StatisticsContext
objects for all filter
operation codes.getStatistics
in interface StatisticsAdmin
StatisticsContext
StatisticsNotAvailable
- when space statistics are not availableRemoteException
- if a communication error occurspublic byte[] getClusterConfigFile() throws RemoteException
IInternalRemoteJSpaceAdmin
getClusterConfigFile
in interface IInternalRemoteJSpaceAdmin
RemoteException
- if a communication error occurspublic void setClusterConfigFile(byte[] config) throws RemoteException
IInternalRemoteJSpaceAdmin
setClusterConfigFile
in interface IInternalRemoteJSpaceAdmin
config
- byte representation of the configuration fileRemoteException
- if a communication error occurspublic SpaceCopyStatus spaceCopy(String remoteUrl, Object template, boolean includeNotifyTemplates, int chunkSize) throws RemoteException
IRemoteJSpaceAdmin
Usage:
SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( sourceSpaceURL, template, false );
System.out.println("Copy-Status: " + copyStatus );
spaceCopy
in interface IRemoteJSpaceAdmin
remoteUrl
- 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 templPacket, boolean includeNotifyTemplates, int chunkSize) throws RemoteException
IInternalRemoteJSpaceAdmin
Usage:
SpaceCopyStatus copyStatus = spaceAdmin.spaceCopy( sourceSpaceURL, template, false );
System.out.println("Copy-Status: " + copyStatus );
spaceCopy
in interface IInternalRemoteJSpaceAdmin
remoteUrl
- url of remote space to copy fromtemplPacket
- 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 IInternalRemoteJSpaceAdmin
remoteUrl
- 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(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 IInternalRemoteJSpaceAdmin
remoteProxy
- 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 SpaceCopyStatus spaceCopy(IJSpace remoteProxy, Object template, boolean includeNotifyTemplates, int chunkSize) throws RemoteException
spaceCopy
in interface IRemoteJSpaceAdmin
RemoteException
public SpaceMode getSpaceMode() throws RemoteException
IInternalRemoteJSpaceAdmin
SpaceMode
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 IInternalRemoteJSpaceAdmin
SpaceMode
of the space.RemoteException
- if an exception occurred executing this remote method.public SpaceMode addSpaceModeListener(ISpaceModeListener listener) throws RemoteException
IInternalRemoteJSpaceAdmin
ISpaceModeListener
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 IInternalRemoteJSpaceAdmin
listener
- a listener to be called back on space mode changes.SpaceMode
of the space.RemoteException
- if an exception occurred executing this remote method.ISpaceModeListener
,
SpaceMode
public void removeSpaceModeListener(ISpaceModeListener listener) throws RemoteException
IInternalRemoteJSpaceAdmin
removeSpaceModeListener
in interface IInternalRemoteJSpaceAdmin
listener
- a listener to be removed.RemoteException
- if an exception occurred executing this remote method.IInternalRemoteJSpaceAdmin.addSpaceModeListener(ISpaceModeListener)
public NIODetails getNIODetails() throws RemoteException
NIOInfoProvider
getNIODetails
in interface NIOInfoProvider
RemoteException
public NIOStatistics getNIOStatistics() throws RemoteException
NIOInfoProvider
getNIOStatistics
in interface NIOInfoProvider
RemoteException
public void enableLRMIMonitoring() throws RemoteException
NIOInfoProvider
NIOInfoProvider.fetchLRMIMonitoringDetails()
enableLRMIMonitoring
in interface NIOInfoProvider
RemoteException
public void disableLRMIMonitoring() throws RemoteException
NIOInfoProvider
NIOInfoProvider.enableLRMIMonitoring()
disableLRMIMonitoring
in interface NIOInfoProvider
RemoteException
public LRMIMonitoringDetails fetchLRMIMonitoringDetails() throws RemoteException
NIOInfoProvider
NIOInfoProvider.enableLRMIMonitoring()
fetchLRMIMonitoringDetails
in interface NIOInfoProvider
RemoteException
public long getCurrentTimestamp() throws RemoteException
getCurrentTimestamp
in interface OSInfoProvider
RemoteException
public OSDetails getOSDetails() throws RemoteException
getOSDetails
in interface OSInfoProvider
RemoteException
public OSStatistics getOSStatistics() throws RemoteException
getOSStatistics
in interface OSInfoProvider
RemoteException
public JVMDetails getJVMDetails() throws RemoteException
getJVMDetails
in interface JVMInfoProvider
RemoteException
public JVMStatistics getJVMStatistics() throws RemoteException
getJVMStatistics
in interface JVMInfoProvider
RemoteException
public void runGc() throws RemoteException
runGc
in interface JVMInfoProvider
RemoteException
public String[] getZones() throws RemoteException
getZones
in interface GridZoneProvider
RemoteException
public void forceMoveToPrimary() throws RemoteException
IInternalRemoteJSpaceAdmin
forceMoveToPrimary
in interface IInternalRemoteJSpaceAdmin
RemoteException
public String getReplicationDump() throws RemoteException
getReplicationDump
in interface IInternalRemoteJSpaceAdmin
RemoteException
public Map<String,LocalCacheDetails> getLocalCacheDetails() throws RemoteException
getLocalCacheDetails
in interface IInternalRemoteJSpaceAdmin
RemoteException
public Map<String,LocalViewDetails> getLocalViewDetails() throws RemoteException
getLocalViewDetails
in interface IInternalRemoteJSpaceAdmin
RemoteException
Copyright © GigaSpaces.