org.openspaces.pu.container.servicegrid

Class PUServiceBeanImpl

java.lang.Object

org.jini.rio.resources.servicecore.ServiceProvider

org.jini.rio.jsb.ServiceBeanAdapter

org.openspaces.pu.container.servicegrid.PUServiceBeanImpl

All Implemented Interfaces:

com.gigaspaces.grid.zone.GridZoneProvider, com.gigaspaces.internal.dump.InternalDumpProcessor, com.gigaspaces.internal.jvm.JVMInfoProvider, com.gigaspaces.internal.os.OSInfoProvider, com.gigaspaces.internal.quiesce.QuiesceAware, com.gigaspaces.lrmi.nio.info.NIOInfoProvider, ServiceProxyAccessor, Remote, MBeanRegistration, NotificationBroadcaster, NotificationEmitter, Administrable, ProxyAccessor, ServerProxyTrust, org.jini.rio.core.jsb.ServiceBean, org.jini.rio.core.jsb.ServiceState, org.jini.rio.core.MonitorableService, org.jini.rio.event.EventProducer, org.jini.rio.jsb.ServiceBeanAdapterMBean, org.jini.rio.resources.servicecore.Service, org.jini.rio.watch.Watchable, PUServiceBean

public class PUServiceBeanImpl
extends org.jini.rio.jsb.ServiceBeanAdapter
implements PUServiceBean, com.gigaspaces.internal.dump.InternalDumpProcessor

Author:

kimchy

Nested Class Summary

Nested classes/interfaces inherited from class org.jini.rio.jsb.ServiceBeanAdapter

org.jini.rio.jsb.ServiceBeanAdapter.SnapshotThread

Field Summary

Fields inherited from class org.jini.rio.jsb.ServiceBeanAdapter

activationID, admin, computeResource, computeResourceObserver, context, contextClassLoader, contextMgr, joiner, jsbState, logDirName, mbeanNoticationInfoList, mbeanServer, objectName, proxy, serviceBeanComponent, serviceClassLoader, serviceID, slaThresholdEventAdapter, snapshotter, state, store, uuid

Fields inherited from class org.jini.rio.resources.servicecore.ServiceProvider

eventTable, watchRegistry

Constructor Summary

Constructors

Constructor and Description
PUServiceBeanImpl()

Method Summary

Modifier and Type	Method and Description
protected void	buildInvocableServices()
protected Object	createProxy()
void	disableLRMIMonitoring()
protected Object	doStart(org.jini.rio.core.jsb.ServiceBeanContext context)
void	enableLRMIMonitoring()
com.gigaspaces.lrmi.LRMIMonitoringDetails	fetchLRMIMonitoringDetails()
ClusterInfo	getClusterInfo()
long	getCurrentTimestamp()
com.gigaspaces.internal.jvm.JVMDetails	getJVMDetails()
com.gigaspaces.internal.jvm.JVMStatistics	getJVMStatistics()
String	getName()
com.gigaspaces.lrmi.nio.info.NIODetails	getNIODetails()
com.gigaspaces.lrmi.nio.info.NIOStatistics	getNIOStatistics()
com.gigaspaces.internal.os.OSDetails	getOSDetails()
com.gigaspaces.internal.os.OSStatistics	getOSStatistics()
String	getPresentationName()
PUDetails	getPUDetails()
PUMonitors	getPUMonitors()
IJSpace	getSpaceDirect(ServiceID serviceID)
com.j_spaces.core.admin.RuntimeHolder	getSpaceRuntimeHolder(ServiceID serviceID)
com.j_spaces.core.filters.StatisticsHolder	getSpaceStatisticsHolder(ServiceID serviceID)
String[]	getZones()
void	initialize(org.jini.rio.core.jsb.ServiceBeanContext context) Override initialize to perform additional initialization
protected void	initializeJMX(Object mbean)
Object	invoke(String serviceBeanName, Map<String,Object> namedArgs)
boolean	isAlive() Return true if the member is alive or not.
boolean	isMemberAliveEnabled() Should this member be checked to see if it is alive or not.
boolean	isStopping()
Object[]	listServiceDetails()
com.gigaspaces.cluster.activeelection.SpaceMode[]	listSpacesModes()
SpaceURL[]	listSpacesURLs()
void	process(com.gigaspaces.internal.dump.InternalDump dump)
void	quiesceStateChanged(com.gigaspaces.admin.quiesce.QuiesceStateChangedEvent quiesceStateChangedEvent)
void	runGc()
void	stop(boolean force)
void	undeployEvent()

Methods inherited from class org.jini.rio.jsb.ServiceBeanAdapter

addAttribute, addAttributes, addNotificationListener, advertise, cleanClassLoaders, createObjectName, destroy, destroy, destroyJMX, doAdvertise, doInitialize, exportDo, getAdmin, getAdminExporter, getAssociationManagement, getAssociations, getDiscoveryManager, getExportedProxy, getExporter, getExporter, getJoinManager, getLookupGroups, getNotificationBroadcasterSupport, getNotificationInfo, getProxy, getProxyVerifier, getServiceBeanContext, getServiceID, getServiceProxy, getSLAEventHandler, getStarted, getStartTime, getState, getUuid, initialize, monitor, ping, postDeregister, postRegister, preDeregister, preRegister, removeNotificationListener, removeNotificationListener, setLookupGroups, start, startHeartbeat, unadvertise

Methods inherited from class org.jini.rio.resources.servicecore.ServiceProvider

fetch, fetch, getConfiguration, getEventTable, getWatchRegistry, register, setConfiguration, setWatchRegistry

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jini.rio.core.jsb.ServiceState

getState

Methods inherited from interface com.sun.jini.start.ServiceProxyAccessor

getServiceProxy

Methods inherited from interface net.jini.admin.Administrable

getAdmin

Methods inherited from interface org.jini.rio.core.MonitorableService

monitor, ping, startHeartbeat

Methods inherited from interface org.jini.rio.event.EventProducer

register

Methods inherited from interface org.jini.rio.watch.Watchable

fetch, fetch

Constructor Detail

PUServiceBeanImpl

public PUServiceBeanImpl()

Method Detail

initializeJMX

protected void initializeJMX(Object mbean)
                      throws Exception

Overrides:

initializeJMX in class org.jini.rio.jsb.ServiceBeanAdapter

Throws:

Exception

createProxy

protected Object createProxy()

Overrides:

createProxy in class org.jini.rio.jsb.ServiceBeanAdapter

doStart

protected Object doStart(org.jini.rio.core.jsb.ServiceBeanContext context)
                  throws Exception

Overrides:

doStart in class org.jini.rio.jsb.ServiceBeanAdapter

Throws:

Exception

initialize

public void initialize(org.jini.rio.core.jsb.ServiceBeanContext context)
                throws Exception

Override initialize to perform additional initialization

Specified by:

initialize in interface org.jini.rio.core.jsb.ServiceBean

Overrides:

initialize in class org.jini.rio.jsb.ServiceBeanAdapter

Throws:

Exception

stop

public void stop(boolean force)

Specified by:

stop in interface org.jini.rio.core.jsb.ServiceBean

Overrides:

stop in class org.jini.rio.jsb.ServiceBeanAdapter

buildInvocableServices

protected void buildInvocableServices()

undeployEvent

public void undeployEvent()

Overrides:

undeployEvent in class org.jini.rio.jsb.ServiceBeanAdapter

isMemberAliveEnabled

public boolean isMemberAliveEnabled()

Description copied from interface: PUServiceBean

Should this member be checked to see if it is alive or not.

Specified by:

isMemberAliveEnabled in interface PUServiceBean

isAlive

public boolean isAlive()
                throws Exception

Description copied from interface: PUServiceBean

Return true if the member is alive or not. Exception indicates that the member is not alive (and allows for further information).

Specified by:

isAlive in interface PUServiceBean

Throws:

Exception

getSpaceDirect

public IJSpace getSpaceDirect(ServiceID serviceID)
                       throws RemoteException

Specified by:

getSpaceDirect in interface PUServiceBean

Throws:

RemoteException

getSpaceRuntimeHolder

public com.j_spaces.core.admin.RuntimeHolder getSpaceRuntimeHolder(ServiceID serviceID)
                                                            throws RemoteException

Specified by:

getSpaceRuntimeHolder in interface PUServiceBean

Throws:

RemoteException

getSpaceStatisticsHolder

public com.j_spaces.core.filters.StatisticsHolder getSpaceStatisticsHolder(ServiceID serviceID)
                                                                    throws RemoteException

Specified by:

getSpaceStatisticsHolder in interface PUServiceBean

Throws:

RemoteException

listSpacesURLs

public SpaceURL[] listSpacesURLs()
                          throws RemoteException

Specified by:

listSpacesURLs in interface PUServiceBean

Throws:

RemoteException

listSpacesModes

public com.gigaspaces.cluster.activeelection.SpaceMode[] listSpacesModes()
                                                                  throws RemoteException

Specified by:

listSpacesModes in interface PUServiceBean

Throws:

RemoteException

getPUMonitors

public PUMonitors getPUMonitors()
                         throws RemoteException

Specified by:

getPUMonitors in interface PUServiceBean

Throws:

RemoteException

getPUDetails

public PUDetails getPUDetails()
                       throws RemoteException

Specified by:

getPUDetails in interface PUServiceBean

Throws:

RemoteException

getPresentationName

public String getPresentationName()
                           throws RemoteException

Specified by:

getPresentationName in interface PUServiceBean

Throws:

RemoteException

getClusterInfo

public ClusterInfo getClusterInfo()
                           throws RemoteException

Specified by:

getClusterInfo in interface PUServiceBean

Throws:

RemoteException

listServiceDetails

public Object[] listServiceDetails()
                            throws RemoteException

Specified by:

listServiceDetails in interface PUServiceBean

Throws:

RemoteException

getNIODetails

public com.gigaspaces.lrmi.nio.info.NIODetails getNIODetails()
                                                      throws RemoteException

Specified by:

getNIODetails in interface com.gigaspaces.lrmi.nio.info.NIOInfoProvider

Throws:

RemoteException

getNIOStatistics

public com.gigaspaces.lrmi.nio.info.NIOStatistics getNIOStatistics()
                                                            throws RemoteException

Specified by:

getNIOStatistics in interface com.gigaspaces.lrmi.nio.info.NIOInfoProvider

Throws:

RemoteException

enableLRMIMonitoring

public void enableLRMIMonitoring()
                          throws RemoteException

Specified by:

enableLRMIMonitoring in interface com.gigaspaces.lrmi.nio.info.NIOInfoProvider

Throws:

RemoteException

disableLRMIMonitoring

public void disableLRMIMonitoring()
                           throws RemoteException

Specified by:

disableLRMIMonitoring in interface com.gigaspaces.lrmi.nio.info.NIOInfoProvider

Throws:

RemoteException

fetchLRMIMonitoringDetails

public com.gigaspaces.lrmi.LRMIMonitoringDetails fetchLRMIMonitoringDetails()
                                                                     throws RemoteException

Specified by:

fetchLRMIMonitoringDetails in interface com.gigaspaces.lrmi.nio.info.NIOInfoProvider

Throws:

RemoteException

getCurrentTimestamp

public long getCurrentTimestamp()
                         throws RemoteException

Specified by:

getCurrentTimestamp in interface com.gigaspaces.internal.os.OSInfoProvider

Throws:

RemoteException

getOSDetails

public com.gigaspaces.internal.os.OSDetails getOSDetails()
                                                  throws RemoteException

Specified by:

getOSDetails in interface com.gigaspaces.internal.os.OSInfoProvider

Throws:

RemoteException

getOSStatistics

public com.gigaspaces.internal.os.OSStatistics getOSStatistics()
                                                        throws RemoteException

Specified by:

getOSStatistics in interface com.gigaspaces.internal.os.OSInfoProvider

Throws:

RemoteException

getJVMDetails

public com.gigaspaces.internal.jvm.JVMDetails getJVMDetails()
                                                     throws RemoteException

Specified by:

getJVMDetails in interface com.gigaspaces.internal.jvm.JVMInfoProvider

Throws:

RemoteException

getJVMStatistics

public com.gigaspaces.internal.jvm.JVMStatistics getJVMStatistics()
                                                           throws RemoteException

Specified by:

getJVMStatistics in interface com.gigaspaces.internal.jvm.JVMInfoProvider

Throws:

RemoteException

runGc

public void runGc()
           throws RemoteException

Specified by:

runGc in interface com.gigaspaces.internal.jvm.JVMInfoProvider

Throws:

RemoteException

getZones

public String[] getZones()
                  throws RemoteException

Specified by:

getZones in interface com.gigaspaces.grid.zone.GridZoneProvider

Throws:

RemoteException

getName

public String getName()

Specified by:

getName in interface com.gigaspaces.internal.dump.InternalDumpProcessor

process

public void process(com.gigaspaces.internal.dump.InternalDump dump)
             throws com.gigaspaces.internal.dump.InternalDumpProcessorFailedException

Specified by:

process in interface com.gigaspaces.internal.dump.InternalDumpProcessor

Throws:

com.gigaspaces.internal.dump.InternalDumpProcessorFailedException

invoke

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

Specified by:

invoke in interface PUServiceBean

Throws:

RemoteException

isStopping

public boolean isStopping()

Specified by:

isStopping in interface PUServiceBean

quiesceStateChanged

public void quiesceStateChanged(com.gigaspaces.admin.quiesce.QuiesceStateChangedEvent quiesceStateChangedEvent)
                         throws RemoteException

Specified by:

quiesceStateChanged in interface com.gigaspaces.internal.quiesce.QuiesceAware

Throws:

RemoteException