Package org.openspaces.admin.internal.pu

Class DefaultProcessingUnitInstance

java.lang.Object

org.openspaces.admin.internal.support.AbstractGridComponent

org.openspaces.admin.internal.pu.DefaultProcessingUnitInstance

All Implemented Interfaces:

Iterable<ServiceDetails>, AdminAware, DiscoverableComponent, GridComponent, InternalMachineAware, InternalOperatingSystemAware, InternalOperatingSystemInfoProvider, InternalProcessingUnitInstance, InternalDiscoverableComponent, InternalGridComponent, InternalTransportAware, InternalTransportInfoProvider, InternalVirtualMachineAware, InternalVirtualMachineInfoProvider, InternalZoneAware, MachineAware, OperatingSystemAware, ProcessingUnitInstance, StatisticsMonitor, TransportAware, VirtualMachineAware, ZoneAware

public class DefaultProcessingUnitInstance
extends AbstractGridComponent
implements InternalProcessingUnitInstance

Author:

kimchy

Field Summary

Fields inherited from class org.openspaces.admin.internal.support.AbstractGridComponent

admin

Fields inherited from interface org.openspaces.admin.StatisticsMonitor

DEFAULT_HISTORY_SIZE, DEFAULT_MONITOR_INTERVAL

Constructor Summary

Constructors

Constructor	Description
DefaultProcessingUnitInstance(ServiceID serviceID, PUDetails puDetails, PUServiceBean puServiceBean, InternalAdmin admin, JVMDetails jvmDetails)

Method Summary

Modifier and Type	Method	Description
boolean	addSpaceInstanceIfMatching(SpaceInstance spaceInstance)	Adds a space instance only if it is one that the processing unit has started.
void	decrement()	Decrements the instance (and destroying it in the process).
void	destroy()	Destroy the instance.
void	disableLRMIMonitoring()
void	enableLRMIMonitoring()
LRMIMonitoringDetails	fetchLRMIMonitoringDetails()
Map<String,AsyncPollingEventContainerServiceDetails>	getAsyncPollingEventContainerDetails()	Returns a map of AsyncPollingEventContainerServiceDetails keyed by their ServiceDetails.getId().
int	getBackupId()	Returns the backup id of the processing unit instance.
ClusterInfo	getClusterInfo()	Returns the cluster info of the processing unit instance.
long	getCurrentTimeInMillis()
SpaceServiceDetails	getEmbeddedSpaceDetails()	Returns the embedded space service details as described by the service started within the processing unit.
SpaceServiceDetails[]	getEmbeddedSpacesDetails()	Returns the embedded space service details as described by the service started within the processing unit.
Map<String,EventContainerServiceDetails>	getEventContainerDetails()	Returns a map of EventContainerServiceDetails keyed by their ServiceDetails.getId().
GridServiceContainer	getGridServiceContainer()	Returns the GridServiceContainer the processing unit is running on.
ServiceID	getGridServiceContainerServiceID()
String	getId()	Returns the Processing unit instance Identifier
int	getInstanceId()	Returns the instance id of the processing unit instance.
JeeServiceDetails	getJeeDetails()	Returns the jee service details of the jee container that was started within this processing unit.
JVMStatistics	getJVMStatistics()
ProcessingUnitInstanceStatistics	getLastStatistics()	This method is non-blocking and should used in conjunction with ProcessingUnitInstance.getStatistics() or StatisticsMonitor.setStatisticsInterval(long, java.util.concurrent.TimeUnit)
MemberAliveIndicatorStatus	getMemberAliveIndicatorStatus()
String	getName()	Returns the name of the processing unit.
NIODetails	getNIODetails()
NIOStatistics	getNIOStatistics()
Map<String,NotifyEventContainerServiceDetails>	getNotifyEventContainerDetails()	Returns a map of NotifyEventContainerServiceDetails keyed by their ServiceDetails.getId().
OSDetails	getOSDetails()
OSStatistics	getOSStatistics()
ProcessingUnitPartition	getPartition()	Returns the processing unit partition this processing unit instance is part of.
Map<String,PollingEventContainerServiceDetails>	getPollingEventContainerDetails()	Returns a map of PollingEventContainerServiceDetails keyed by their ServiceDetails.getId().
ProcessingUnit	getProcessingUnit()	Returns the processing unit this processing unit instance belongs to.
String	getProcessingUnitInstanceName()	Get this processing unit instance String representation. If this processing unit instance represents a Space instance, this method will return a similar result to SpaceInstance.getSpaceInstanceName(), but with the processing unit name as the Space name.
String	getProcessingUnitInstanceSimpleName()
BeanLevelProperties	getProperties()	Return the properties the processing unit was deployed with.
PUServiceBean	getPUServiceBean()
RemotingServiceDetails	getRemotingDetails()	Returns the remoting service details (the exporter) if configured within the processing unit.
Map<String,ServiceDetails>	getServiceDetailsByServiceId()	Returns a map of service details by service id.
ServiceDetails	getServiceDetailsByServiceId(String serviceId)	Returns the service details for a specific service id.
Map<String,ServiceDetails[]>	getServiceDetailsByServiceType()	Returns a map of service details by service type.
ServiceID	getServiceID()
ServiceDetails[]	getServicesDetails()
ServiceDetails[]	getServicesDetailsByServiceType(String serviceType)	Returns the service details by a service type ServiceDetails.getServiceType().
SpaceServiceDetails[]	getSpaceDetails()	Returns the space service details as described by the service started within the processing unit.
SpaceInstance	getSpaceInstance()	Returns a space instance that was started within the processing unit instance.
SpaceInstance[]	getSpaceInstances()	Returns all the space instances that were started within the processing unit instance.
ProcessingUnitInstanceStatistics	getStatistics()	Returns the processing unit instance statistics.
long	getStatisticsIntervalMilliseconds()
String	getUid()	Returns the unique id of the grid component.
Future<Object>	invoke(String serviceBeanName, Map<String,Object> namedArgs)
boolean	isEmbeddedSpaces()	Returns true if there are embedded spaces started within this processing unit.
boolean	isJee()	Returns true if this processing unit is a jee processing unit.
boolean	isMonitoring()	Returns true if statistics are now being monitored.
boolean	isUndeploying()
Iterator<ServiceDetails>	iterator()
void	relocate()	Relocates the instance to any suitable GridServiceContainer.
void	relocate(GridServiceContainer gridServiceContainerToRelocateTo)	Relocates the instance to the provided GridServiceContainer.
ProcessingUnitInstance	relocateAndWait()	Relocates the any suitable GridServiceContainer.
ProcessingUnitInstance	relocateAndWait(long timeout, TimeUnit timeUnit)	Relocates the any suitable GridServiceContainer.
ProcessingUnitInstance	relocateAndWait(GridServiceContainer gridServiceContainerToRelocateTo)	Relocates the instance to the provided GridServiceContainer.
ProcessingUnitInstance	relocateAndWait(GridServiceContainer gridServiceContainerToRelocateTo, long timeout, TimeUnit timeUnit)	Relocates the instance to the provided GridServiceContainer.
void	removeSpaceInstance(String uid)
void	restart()	Restarts the processing unit instance.
ProcessingUnitInstance	restartAndWait()	Restarts the processing unit instance and waits indefinitely for the restarted processing unit instance returning it.
ProcessingUnitInstance	restartAndWait(long timeout, TimeUnit timeUnit)	Restarts the processing unit instance and waits for the restarted processing unit instance returning it for the provided timeout.
void	runGc()
void	setClusterInfo(ClusterInfo clusterInfo)
void	setGridServiceContainer(GridServiceContainer gridServiceContainer)
void	setMemberAliveIndicatorStatus(org.jini.rio.monitor.ServiceFaultDetectionEvent serviceFaultDetectionEvent)
void	setProcessingUnit(ProcessingUnit processingUnit)
void	setProcessingUnitPartition(ProcessingUnitPartition processingUnitPartition)
void	setStatisticsHistorySize(int historySize)	Sets the history size of number of statistics stored.
void	setStatisticsInterval(long interval, TimeUnit timeUnit)	Sets the statistics interval, automatically updating the monitoring scheduled tasks if monitoring is enabled.
void	startStatisticsMonitor()	Starts the statistics monitor, starting a scheduled monitor that polls for statistics.
void	stopStatisticsMonitor()	Stops the statistics monitor.
SpaceInstance	waitForSpaceInstance()
SpaceInstance	waitForSpaceInstance(long timeout, TimeUnit timeUnit)

Methods inherited from class org.openspaces.admin.internal.support.AbstractGridComponent

addZone, assertStateChangesPermitted, getAdmin, getJVMDetails, getMachine, getOperatingSystem, getTransport, getVirtualMachine, getZones, isDiscovered, setDiscovered, setMachine, setOperatingSystem, setTransport, setVirtualMachine

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openspaces.admin.AdminAware

getAdmin

Methods inherited from interface org.openspaces.admin.DiscoverableComponent

isDiscovered

Methods inherited from interface org.openspaces.admin.internal.support.InternalDiscoverableComponent

setDiscovered

Methods inherited from interface org.openspaces.admin.internal.machine.InternalMachineAware

setMachine

Methods inherited from interface org.openspaces.admin.internal.os.InternalOperatingSystemAware

setOperatingSystem

Methods inherited from interface org.openspaces.admin.internal.transport.InternalTransportAware

setTransport

Methods inherited from interface org.openspaces.admin.internal.vm.InternalVirtualMachineAware

setVirtualMachine

Methods inherited from interface org.openspaces.admin.internal.vm.InternalVirtualMachineInfoProvider

getJVMDetails

Methods inherited from interface org.openspaces.admin.internal.zone.InternalZoneAware

addZone

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.openspaces.admin.machine.MachineAware

getMachine

Methods inherited from interface org.openspaces.admin.os.OperatingSystemAware

getOperatingSystem

Methods inherited from interface org.openspaces.admin.transport.TransportAware

getTransport

Methods inherited from interface org.openspaces.admin.vm.VirtualMachineAware

getVirtualMachine

Methods inherited from interface org.openspaces.admin.zone.ZoneAware

getZones

Constructor Details

DefaultProcessingUnitInstance

public DefaultProcessingUnitInstance(ServiceID serviceID,
 PUDetails puDetails,
 PUServiceBean puServiceBean,
 InternalAdmin admin,
 JVMDetails jvmDetails)

Method Details

getUid

public String getUid()

Description copied from interface: GridComponent

Returns the unique id of the grid component.

Specified by:

getUid in interface GridComponent

Specified by:

getUid in interface InternalVirtualMachineInfoProvider

getId

public String getId()

Description copied from interface: ProcessingUnitInstance

Returns the Processing unit instance Identifier

Specified by:

getId in interface ProcessingUnitInstance

getInstanceId

public int getInstanceId()

Description copied from interface: ProcessingUnitInstance

Returns the instance id of the processing unit instance.

Specified by:

getInstanceId in interface ProcessingUnitInstance

getBackupId

public int getBackupId()

Description copied from interface: ProcessingUnitInstance

Returns the backup id of the processing unit instance.

Specified by:

getBackupId in interface ProcessingUnitInstance

getServiceID

public ServiceID getServiceID()

Specified by:

getServiceID in interface InternalProcessingUnitInstance

getProcessingUnit

public ProcessingUnit getProcessingUnit()

Description copied from interface: ProcessingUnitInstance

Returns the processing unit this processing unit instance belongs to.

Specified by:

getProcessingUnit in interface ProcessingUnitInstance

getName

public String getName()

Description copied from interface: ProcessingUnitInstance

Returns the name of the processing unit.

Specified by:

getName in interface ProcessingUnitInstance

getProcessingUnitInstanceName

public String getProcessingUnitInstanceName()

Description copied from interface: ProcessingUnitInstance

Get this processing unit instance String representation.
If this processing unit instance represents a Space instance, this method will return a similar result to SpaceInstance.getSpaceInstanceName(), but with the processing unit name as the Space name. Otherwise, it will return: {Processing unit name} [instance id] - the name of this processing unit (see ProcessingUnitInstance.getName()) and the instance id (see ProcessingUnitInstance.getInstanceId()); for example, MyPU [3]

Specified by:

getProcessingUnitInstanceName in interface ProcessingUnitInstance

Returns:

this processing unit instance String representation.

getProcessingUnitInstanceSimpleName

public String getProcessingUnitInstanceSimpleName()

Specified by:

getProcessingUnitInstanceSimpleName in interface InternalProcessingUnitInstance

Returns:

Return instance name without prefix of application name ( if exists )

setProcessingUnit

public void setProcessingUnit(ProcessingUnit processingUnit)

Specified by:

setProcessingUnit in interface InternalProcessingUnitInstance

getClusterInfo

public ClusterInfo getClusterInfo()

Description copied from interface: ProcessingUnitInstance

Returns the cluster info of the processing unit instance.

Specified by:

getClusterInfo in interface ProcessingUnitInstance

getProperties

public BeanLevelProperties getProperties()

Description copied from interface: ProcessingUnitInstance

Return the properties the processing unit was deployed with.

Specified by:

getProperties in interface ProcessingUnitInstance

iterator

public Iterator<ServiceDetails> iterator()

Specified by:

iterator in interface Iterable<ServiceDetails>

getEventContainerDetails

public Map<String,EventContainerServiceDetails> getEventContainerDetails()

Description copied from interface: ProcessingUnitInstance

Returns a map of EventContainerServiceDetails keyed by their ServiceDetails.getId().

Specified by:

getEventContainerDetails in interface ProcessingUnitInstance

getPollingEventContainerDetails

public Map<String,PollingEventContainerServiceDetails> getPollingEventContainerDetails()

Description copied from interface: ProcessingUnitInstance

Returns a map of PollingEventContainerServiceDetails keyed by their ServiceDetails.getId().

Specified by:

getPollingEventContainerDetails in interface ProcessingUnitInstance

getNotifyEventContainerDetails

public Map<String,NotifyEventContainerServiceDetails> getNotifyEventContainerDetails()

Description copied from interface: ProcessingUnitInstance

Returns a map of NotifyEventContainerServiceDetails keyed by their ServiceDetails.getId().

Specified by:

getNotifyEventContainerDetails in interface ProcessingUnitInstance

getAsyncPollingEventContainerDetails

public Map<String,AsyncPollingEventContainerServiceDetails> getAsyncPollingEventContainerDetails()

Description copied from interface: ProcessingUnitInstance

Returns a map of AsyncPollingEventContainerServiceDetails keyed by their ServiceDetails.getId().

Specified by:

getAsyncPollingEventContainerDetails in interface ProcessingUnitInstance

getSpaceDetails

public SpaceServiceDetails[] getSpaceDetails()

Description copied from interface: ProcessingUnitInstance

Returns the space service details as described by the service started within the processing unit.

Specified by:

getSpaceDetails in interface ProcessingUnitInstance

getEmbeddedSpaceDetails

public SpaceServiceDetails getEmbeddedSpaceDetails()

Description copied from interface: ProcessingUnitInstance

Returns the embedded space service details as described by the service started within the processing unit. null if no embedded space was started within the processing unit.

Specified by:

getEmbeddedSpaceDetails in interface ProcessingUnitInstance

getEmbeddedSpacesDetails

public SpaceServiceDetails[] getEmbeddedSpacesDetails()

Description copied from interface: ProcessingUnitInstance

Returns the embedded space service details as described by the service started within the processing unit.

Specified by:

getEmbeddedSpacesDetails in interface ProcessingUnitInstance

getServicesDetails

public ServiceDetails[] getServicesDetails()

getGridServiceContainerServiceID

public ServiceID getGridServiceContainerServiceID()

Specified by:

getGridServiceContainerServiceID in interface InternalProcessingUnitInstance

setGridServiceContainer

public void setGridServiceContainer(GridServiceContainer gridServiceContainer)

Specified by:

setGridServiceContainer in interface InternalProcessingUnitInstance

getGridServiceContainer

public GridServiceContainer getGridServiceContainer()

Description copied from interface: ProcessingUnitInstance

Returns the GridServiceContainer the processing unit is running on.

Specified by:

getGridServiceContainer in interface ProcessingUnitInstance

setProcessingUnitPartition

public void setProcessingUnitPartition(ProcessingUnitPartition processingUnitPartition)

Specified by:

setProcessingUnitPartition in interface InternalProcessingUnitInstance

getPartition

public ProcessingUnitPartition getPartition()

Description copied from interface: ProcessingUnitInstance

Returns the processing unit partition this processing unit instance is part of.

Specified by:

getPartition in interface ProcessingUnitInstance

getPUServiceBean

public PUServiceBean getPUServiceBean()

Specified by:

getPUServiceBean in interface InternalProcessingUnitInstance

isEmbeddedSpaces

public boolean isEmbeddedSpaces()

Description copied from interface: ProcessingUnitInstance

Returns true if there are embedded spaces started within this processing unit.

Specified by:

isEmbeddedSpaces in interface ProcessingUnitInstance

getSpaceInstance

public SpaceInstance getSpaceInstance()

Description copied from interface: ProcessingUnitInstance

Returns a space instance that was started within the processing unit instance. Will return null if no embedded space instances were started (or none has been detected yet).

Specified by:

getSpaceInstance in interface ProcessingUnitInstance

getSpaceInstances

public SpaceInstance[] getSpaceInstances()

Description copied from interface: ProcessingUnitInstance

Returns all the space instances that were started within the processing unit instance. Will return an empty array if no space instances were started within this processing unit (or none has been detected yet).

Specified by:

getSpaceInstances in interface ProcessingUnitInstance

waitForSpaceInstance

public SpaceInstance waitForSpaceInstance()

Specified by:

waitForSpaceInstance in interface ProcessingUnitInstance

waitForSpaceInstance

public SpaceInstance waitForSpaceInstance(long timeout,
 TimeUnit timeUnit)

Specified by:

waitForSpaceInstance in interface ProcessingUnitInstance

addSpaceInstanceIfMatching

public boolean addSpaceInstanceIfMatching(SpaceInstance spaceInstance)

Description copied from interface: InternalProcessingUnitInstance

Adds a space instance only if it is one that the processing unit has started.

Specified by:

addSpaceInstanceIfMatching in interface InternalProcessingUnitInstance

removeSpaceInstance

public void removeSpaceInstance(String uid)

Specified by:

removeSpaceInstance in interface InternalProcessingUnitInstance

isJee

public boolean isJee()

Description copied from interface: ProcessingUnitInstance

Returns true if this processing unit is a jee processing unit.

Specified by:

isJee in interface ProcessingUnitInstance

getJeeDetails

public JeeServiceDetails getJeeDetails()

Description copied from interface: ProcessingUnitInstance

Returns the jee service details of the jee container that was started within this processing unit.

Specified by:

getJeeDetails in interface ProcessingUnitInstance

getRemotingDetails

public RemotingServiceDetails getRemotingDetails()

Description copied from interface: ProcessingUnitInstance

Returns the remoting service details (the exporter) if configured within the processing unit.

Specified by:

getRemotingDetails in interface ProcessingUnitInstance

getServiceDetailsByServiceId

public ServiceDetails getServiceDetailsByServiceId(String serviceId)

Description copied from interface: ProcessingUnitInstance

Returns the service details for a specific service id.

Specified by:

getServiceDetailsByServiceId in interface ProcessingUnitInstance

getServiceDetailsByServiceId

public Map<String,ServiceDetails> getServiceDetailsByServiceId()

Description copied from interface: ProcessingUnitInstance

Returns a map of service details by service id.

Specified by:

getServiceDetailsByServiceId in interface ProcessingUnitInstance

getServicesDetailsByServiceType

public ServiceDetails[] getServicesDetailsByServiceType(String serviceType)

Description copied from interface: ProcessingUnitInstance

Returns the service details by a service type ServiceDetails.getServiceType().

Specified by:

getServicesDetailsByServiceType in interface ProcessingUnitInstance

getServiceDetailsByServiceType

public Map<String,ServiceDetails[]> getServiceDetailsByServiceType()

Description copied from interface: ProcessingUnitInstance

Returns a map of service details by service type.

Specified by:

getServiceDetailsByServiceType in interface ProcessingUnitInstance

destroy

public void destroy()

Description copied from interface: ProcessingUnitInstance

Destroy the instance. If breaches the SLA, will instantiate the instance again.

Specified by:

destroy in interface ProcessingUnitInstance

relocate

public void relocate(GridServiceContainer gridServiceContainerToRelocateTo)

Description copied from interface: ProcessingUnitInstance

Relocates the instance to the provided GridServiceContainer.

Note, the current processing instance is unusable once this call has been made. If the relocated processing unit instance is needed, or waiting for the relocation is required, use ProcessingUnitInstance.relocateAndWait(org.openspaces.admin.gsc.GridServiceContainer) or ProcessingUnitInstance.relocateAndWait(org.openspaces.admin.gsc.GridServiceContainer, long, java.util.concurrent.TimeUnit).

Specified by:

relocate in interface ProcessingUnitInstance

relocateAndWait

public ProcessingUnitInstance relocateAndWait(GridServiceContainer gridServiceContainerToRelocateTo)

Description copied from interface: ProcessingUnitInstance

Relocates the instance to the provided GridServiceContainer. The relocated instance will be returned waiting for it indefinitely.

Specified by:

relocateAndWait in interface ProcessingUnitInstance

relocateAndWait

public ProcessingUnitInstance relocateAndWait(GridServiceContainer gridServiceContainerToRelocateTo,
 long timeout,
 TimeUnit timeUnit)

Description copied from interface: ProcessingUnitInstance

Relocates the instance to the provided GridServiceContainer. The relocated instance will be returned waiting for it for the provided timeout.

Specified by:

relocateAndWait in interface ProcessingUnitInstance

relocate

public void relocate()

Description copied from interface: ProcessingUnitInstance

Relocates the instance to any suitable GridServiceContainer.

Note, the current processing instance is unusable once this call has been made. If the relocated processing unit instance is needed, or waiting for the relocation is required, use ProcessingUnitInstance.relocateAndWait() or ProcessingUnitInstance.relocateAndWait(long, java.util.concurrent.TimeUnit) .

Specified by:

relocate in interface ProcessingUnitInstance

relocateAndWait

public ProcessingUnitInstance relocateAndWait()

Description copied from interface: ProcessingUnitInstance

Relocates the any suitable GridServiceContainer. The relocated instance will be returned waiting for it indefinitely.

Specified by:

relocateAndWait in interface ProcessingUnitInstance

relocateAndWait

public ProcessingUnitInstance relocateAndWait(long timeout,
 TimeUnit timeUnit)

Description copied from interface: ProcessingUnitInstance

Relocates the any suitable GridServiceContainer. The relocated instance will be returned waiting for it for the provided timeout.

Specified by:

relocateAndWait in interface ProcessingUnitInstance

restart

public void restart()

Description copied from interface: ProcessingUnitInstance

Restarts the processing unit instance. Note, if this instance is running an embedded space instance, and the space instance is primary and there is a backup around as well, this method is handy to "turn" the backup to primary.

Note, the current processing unit instance is unusable once this call has been made. If the restarted processing unit instance is needed, or waiting for the restart is required, use ProcessingUnitInstance.restartAndWait() or ProcessingUnitInstance.restartAndWait(long, java.util.concurrent.TimeUnit).

Specified by:

restart in interface ProcessingUnitInstance

restartAndWait

public ProcessingUnitInstance restartAndWait()

Description copied from interface: ProcessingUnitInstance

Restarts the processing unit instance and waits indefinitely for the restarted processing unit instance returning it.

Specified by:

restartAndWait in interface ProcessingUnitInstance

See Also:

• ProcessingUnitInstance.restart()

restartAndWait

public ProcessingUnitInstance restartAndWait(long timeout,
 TimeUnit timeUnit)

Description copied from interface: ProcessingUnitInstance

Restarts the processing unit instance and waits for the restarted processing unit instance returning it for the provided timeout.

Specified by:

restartAndWait in interface ProcessingUnitInstance

See Also:

• ProcessingUnitInstance.restart()

decrement

public void decrement()

Description copied from interface: ProcessingUnitInstance

Decrements the instance (and destroying it in the process). Will not attempt to create it again. Does not apply for partitioned nor replicated topologies.

Specified by:

decrement in interface ProcessingUnitInstance

See Also:

• ProcessingUnit.canDecrementInstance()

getLastStatistics

public ProcessingUnitInstanceStatistics getLastStatistics()

Description copied from interface: InternalProcessingUnitInstance

This method is non-blocking and should used in conjunction with ProcessingUnitInstance.getStatistics() or StatisticsMonitor.setStatisticsInterval(long, java.util.concurrent.TimeUnit)

Specified by:

getLastStatistics in interface InternalProcessingUnitInstance

Returns:

the last statistics (regardless of its timestamp), or null if no statistics has been ever collected.

getStatistics

public ProcessingUnitInstanceStatistics getStatistics()

Description copied from interface: ProcessingUnitInstance

Returns the processing unit instance statistics.

Specified by:

getStatistics in interface ProcessingUnitInstance

setStatisticsInterval

public void setStatisticsInterval(long interval,
 TimeUnit timeUnit)

Description copied from interface: StatisticsMonitor

Sets the statistics interval, automatically updating the monitoring scheduled tasks if monitoring is enabled.

Specified by:

setStatisticsInterval in interface StatisticsMonitor

getStatisticsIntervalMilliseconds

public long getStatisticsIntervalMilliseconds()

Specified by:

getStatisticsIntervalMilliseconds in interface InternalProcessingUnitInstance

Returns:

the statistics interval milliseconds

setClusterInfo

public void setClusterInfo(ClusterInfo clusterInfo)

Specified by:

setClusterInfo in interface InternalProcessingUnitInstance

setStatisticsHistorySize

public void setStatisticsHistorySize(int historySize)

Description copied from interface: StatisticsMonitor

Sets the history size of number of statistics stored.

Specified by:

setStatisticsHistorySize in interface StatisticsMonitor

startStatisticsMonitor

public void startStatisticsMonitor()

Description copied from interface: StatisticsMonitor

Starts the statistics monitor, starting a scheduled monitor that polls for statistics. Monitoring is required only when wanting to receive statistics change events.

Specified by:

startStatisticsMonitor in interface StatisticsMonitor

stopStatisticsMonitor

public void stopStatisticsMonitor()

Description copied from interface: StatisticsMonitor

Stops the statistics monitor.

Specified by:

stopStatisticsMonitor in interface StatisticsMonitor

isMonitoring

public boolean isMonitoring()

Description copied from interface: StatisticsMonitor

Returns true if statistics are now being monitored.

Specified by:

isMonitoring in interface StatisticsMonitor

getNIODetails

public NIODetails getNIODetails()
                         throws RemoteException

Specified by:

getNIODetails in interface InternalTransportInfoProvider

Throws:

RemoteException

getNIOStatistics

public NIOStatistics getNIOStatistics()
                               throws RemoteException

Specified by:

getNIOStatistics in interface InternalTransportInfoProvider

Throws:

RemoteException

enableLRMIMonitoring

public void enableLRMIMonitoring()
                          throws RemoteException

Specified by:

enableLRMIMonitoring in interface InternalTransportInfoProvider

Throws:

RemoteException

disableLRMIMonitoring

public void disableLRMIMonitoring()
                           throws RemoteException

Specified by:

disableLRMIMonitoring in interface InternalTransportInfoProvider

Throws:

RemoteException

fetchLRMIMonitoringDetails

public LRMIMonitoringDetails fetchLRMIMonitoringDetails()
                                                 throws RemoteException

Specified by:

fetchLRMIMonitoringDetails in interface InternalTransportInfoProvider

Throws:

RemoteException

getCurrentTimeInMillis

public long getCurrentTimeInMillis()
                            throws RemoteException

Specified by:

getCurrentTimeInMillis in interface InternalOperatingSystemInfoProvider

Throws:

RemoteException

getOSDetails

public OSDetails getOSDetails()
                       throws RemoteException

Specified by:

getOSDetails in interface InternalOperatingSystemInfoProvider

Throws:

RemoteException

getOSStatistics

public OSStatistics getOSStatistics()
                             throws RemoteException

Specified by:

getOSStatistics in interface InternalOperatingSystemInfoProvider

Throws:

RemoteException

getJVMStatistics

public JVMStatistics getJVMStatistics()
                               throws RemoteException

Specified by:

getJVMStatistics in interface InternalVirtualMachineInfoProvider

Throws:

RemoteException

runGc

public void runGc()
           throws RemoteException

Specified by:

runGc in interface InternalVirtualMachineInfoProvider

Throws:

RemoteException

invoke

public Future<Object> invoke(String serviceBeanName,
 Map<String,Object> namedArgs)

Specified by:

invoke in interface InternalProcessingUnitInstance

isUndeploying

public boolean isUndeploying()

Specified by:

isUndeploying in interface InternalProcessingUnitInstance

setMemberAliveIndicatorStatus

public void setMemberAliveIndicatorStatus(org.jini.rio.monitor.ServiceFaultDetectionEvent serviceFaultDetectionEvent)

Specified by:

setMemberAliveIndicatorStatus in interface InternalProcessingUnitInstance

getMemberAliveIndicatorStatus

public MemberAliveIndicatorStatus getMemberAliveIndicatorStatus()

Specified by:

getMemberAliveIndicatorStatus in interface ProcessingUnitInstance

Returns:

Returns the current member alive indicator status of this processing unit instance.