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:

GridZoneProvider, InternalDumpProcessor, JVMInfoProvider, OSInfoProvider, QuiesceAware, NIOInfoProvider, ServiceProxyAccessor, Remote, MBeanRegistration, NotificationBroadcaster, NotificationEmitter, Administrable, ProxyAccessor, ServerProxyTrust, org.jini.rio.core.jsb.ServiceBean, ServiceState, MonitorableService, EventProducer, org.jini.rio.jsb.ServiceBeanAdapterMBean, Service, Watchable, PUServiceBean

public class PUServiceBeanImpl
extends org.jini.rio.jsb.ServiceBeanAdapter
implements PUServiceBean, 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

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() Disabled lrmi monitoring (gigaspaces internal remoting layer).
protected Object	doStart(org.jini.rio.core.jsb.ServiceBeanContext context)
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.
ClusterInfo	getClusterInfo()
long	getCurrentTimestamp()
JVMDetails	getJVMDetails()
JVMStatistics	getJVMStatistics()
String	getName()
NIODetails	getNIODetails() Returns the transport configuration.
NIOStatistics	getNIOStatistics() Returns the transport statistics.
OSDetails	getOSDetails()
OSStatistics	getOSStatistics()
String	getPresentationName()
PUDetails	getPUDetails()
PUMonitors	getPUMonitors()
InternalQuiesceDetails	getQuiesceDetails()
IJSpace	getSpaceDirect(ServiceID serviceID)
DirectSpaceProxyFactory	getSpaceDirectFactory(ServiceID serviceID)
RuntimeHolder	getSpaceRuntimeHolder(ServiceID serviceID)
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()
SpaceMode[]	listSpacesModes()
SpaceURL[]	listSpacesURLs()
void	process(InternalDump dump)
void	quiesceStateChanged(QuiesceStateChangedEvent quiesceStateChangedEvent)
void	runGc()
void	stop(boolean force)
void	undeployEvent()
void	updateClusterInfo()

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

updateClusterInfo

public void updateClusterInfo()

Specified by:

updateClusterInfo in interface PUServiceBean

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

getSpaceDirectFactory

public DirectSpaceProxyFactory getSpaceDirectFactory(ServiceID serviceID)
                                              throws RemoteException

Specified by:

getSpaceDirectFactory in interface PUServiceBean

Throws:

RemoteException

getSpaceRuntimeHolder

public RuntimeHolder getSpaceRuntimeHolder(ServiceID serviceID)
                                    throws RemoteException

Specified by:

getSpaceRuntimeHolder in interface PUServiceBean

Throws:

RemoteException

getSpaceStatisticsHolder

public 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 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 NIODetails getNIODetails()
                         throws RemoteException

Description copied from interface: NIOInfoProvider

Returns the transport configuration. Note, does not change during application lifecycle, should be cached on the client side.

Specified by:

getNIODetails in interface NIOInfoProvider

Throws:

RemoteException

getNIOStatistics

public NIOStatistics getNIOStatistics()
                               throws RemoteException

Description copied from interface: NIOInfoProvider

Returns the transport statistics.

Specified by:

getNIOStatistics in interface NIOInfoProvider

Throws:

RemoteException

enableLRMIMonitoring

public void enableLRMIMonitoring()
                          throws RemoteException

Description copied from interface: NIOInfoProvider

Enables lrmi monitoring (gigaspaces internal remoting layer), this will cause the target to start track lrmi invocations which can later be viewed by calling. NIOInfoProvider.fetchLRMIMonitoringDetails()

Specified by:

enableLRMIMonitoring in interface NIOInfoProvider

Throws:

RemoteException

disableLRMIMonitoring

public void disableLRMIMonitoring()
                           throws RemoteException

Description copied from interface: NIOInfoProvider

Disabled lrmi monitoring (gigaspaces internal remoting layer). NIOInfoProvider.enableLRMIMonitoring()

Specified by:

disableLRMIMonitoring in interface NIOInfoProvider

Throws:

RemoteException

fetchLRMIMonitoringDetails

public LRMIMonitoringDetails fetchLRMIMonitoringDetails()
                                                 throws RemoteException

Description copied from interface: NIOInfoProvider

Return lrmi (gigaspaces internal remoting layer) services monitoring details. This will only work if lrmi monitoring was previously enabled, either by admin API, Jmx or system property. NIOInfoProvider.enableLRMIMonitoring()

Specified by:

fetchLRMIMonitoringDetails in interface NIOInfoProvider

Throws:

RemoteException

getCurrentTimestamp

public long getCurrentTimestamp()
                         throws RemoteException

Specified by:

getCurrentTimestamp in interface OSInfoProvider

Throws:

RemoteException

getOSDetails

public OSDetails getOSDetails()
                       throws RemoteException

Specified by:

getOSDetails in interface OSInfoProvider

Throws:

RemoteException

getOSStatistics

public OSStatistics getOSStatistics()
                             throws RemoteException

Specified by:

getOSStatistics in interface OSInfoProvider

Throws:

RemoteException

getJVMDetails

public JVMDetails getJVMDetails()
                         throws RemoteException

Specified by:

getJVMDetails in interface JVMInfoProvider

Throws:

RemoteException

getJVMStatistics

public JVMStatistics getJVMStatistics()
                               throws RemoteException

Specified by:

getJVMStatistics in interface JVMInfoProvider

Throws:

RemoteException

runGc

public void runGc()
           throws RemoteException

Specified by:

runGc in interface JVMInfoProvider

Throws:

RemoteException

getZones

public String[] getZones()
                  throws RemoteException

Specified by:

getZones in interface GridZoneProvider

Throws:

RemoteException

getName

public String getName()

Specified by:

getName in interface InternalDumpProcessor

process

public void process(InternalDump dump)
             throws InternalDumpProcessorFailedException

Specified by:

process in interface InternalDumpProcessor

Throws:

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

getQuiesceDetails

public InternalQuiesceDetails getQuiesceDetails()

quiesceStateChanged

public void quiesceStateChanged(QuiesceStateChangedEvent quiesceStateChangedEvent)
                         throws RemoteException

Specified by:

quiesceStateChanged in interface QuiesceAware

Throws:

RemoteException