org.openspaces.grid.esm
Class ESMImpl

java.lang.Object
  org.jini.rio.resources.servicecore.ServiceProvider
      org.jini.rio.jsb.ServiceBeanAdapter
          org.openspaces.grid.esm.ESMImpl

All Implemented Interfaces:

com.gigaspaces.grid.esm.ESM, com.gigaspaces.grid.gsa.AgentIdAware, com.gigaspaces.grid.zone.GridZoneProvider, com.gigaspaces.internal.dump.InternalDumpProvider, com.gigaspaces.internal.jvm.JVMInfoProvider, com.gigaspaces.internal.log.InternalLogProvider, com.gigaspaces.internal.os.OSInfoProvider, com.gigaspaces.lrmi.nio.info.NIOInfoProvider, com.gigaspaces.security.service.SecuredService, com.sun.jini.start.ServiceProxyAccessor, Remote, MBeanRegistration, NotificationBroadcaster, NotificationEmitter, net.jini.admin.Administrable, net.jini.export.ProxyAccessor, net.jini.security.proxytrust.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

public class ESMImpl
extends org.jini.rio.jsb.ServiceBeanAdapter
implements ESM

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

ESMImpl()
Create an ESM

ESMImpl(String[] configArgs, com.sun.jini.start.LifeCycle lifeCycle)
Create an ESM launched from the ServiceStarter framework

Method Summary

void	advertise()
protected void	bootstrap(String[] configArgs)
protected Object	createProxy()
void	deploy(ElasticDataGridDeployment deployment)
void	destroy(boolean force)
byte[]	dumpBytes(String file, long from, int length)
com.gigaspaces.internal.dump.InternalDumpResult	generateDump(String cause, Map<String,Object> context)
com.gigaspaces.internal.dump.InternalDumpResult	generateDump(String cause, Map<String,Object> context, String... contributors)
int	getAgentId()
long	getCurrentTimestamp()
String	getGSAServiceID()
com.gigaspaces.internal.jvm.JVMDetails	getJVMDetails()
com.gigaspaces.internal.jvm.JVMStatistics	getJVMStatistics()
String[]	getManagedProcessingUnits()
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[]	getZones()
void	initialize(org.jini.rio.core.jsb.ServiceBeanContext context)
boolean	isServiceSecured()
LogEntries	logEntriesDirect(LogEntryMatcher matcher)
SecurityContext	login(UserDetails userDetails)
void	runGc()

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

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

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 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

ESMImpl

public ESMImpl()
        throws Exception

Create an ESM

Throws:

Exception

ESMImpl

public ESMImpl(String[] configArgs,
               com.sun.jini.start.LifeCycle lifeCycle)
        throws Exception

Create an ESM launched from the ServiceStarter framework

Throws:

Exception

Method Detail

bootstrap

protected void bootstrap(String[] configArgs)
                  throws Exception

Throws:

Exception

initialize

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

Specified by:

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

Overrides:

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

Throws:

Exception

advertise

public void advertise()
               throws IOException

Specified by:

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

Specified by:

advertise in interface org.jini.rio.jsb.ServiceBeanAdapterMBean

Overrides:

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

Throws:

IOException

destroy

public void destroy(boolean force)

Specified by:

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

Specified by:

destroy in interface org.jini.rio.jsb.ServiceBeanAdapterMBean

Overrides:

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

createProxy

protected Object createProxy()

Overrides:

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

getAgentId

public int getAgentId()
               throws RemoteException

Specified by:

getAgentId in interface com.gigaspaces.grid.gsa.AgentIdAware

Throws:

RemoteException

getGSAServiceID

public String getGSAServiceID()
                       throws RemoteException

Specified by:

getGSAServiceID in interface com.gigaspaces.grid.gsa.AgentIdAware

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

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

logEntriesDirect

public LogEntries logEntriesDirect(LogEntryMatcher matcher)
                            throws RemoteException,
                                   IOException

Specified by:

logEntriesDirect in interface com.gigaspaces.internal.log.InternalLogProvider

Throws:

RemoteException

IOException

dumpBytes

public byte[] dumpBytes(String file,
                        long from,
                        int length)
                 throws RemoteException,
                        IOException

Specified by:

dumpBytes in interface com.gigaspaces.internal.dump.InternalDumpProvider

Throws:

RemoteException

IOException

generateDump

public com.gigaspaces.internal.dump.InternalDumpResult generateDump(String cause,
                                                                    Map<String,Object> context)
                                                             throws RemoteException,
                                                                    com.gigaspaces.internal.dump.InternalDumpException

Specified by:

generateDump in interface com.gigaspaces.internal.dump.InternalDumpProvider

Throws:

RemoteException

com.gigaspaces.internal.dump.InternalDumpException

generateDump

public com.gigaspaces.internal.dump.InternalDumpResult generateDump(String cause,
                                                                    Map<String,Object> context,
                                                                    String... contributors)
                                                             throws RemoteException,
                                                                    com.gigaspaces.internal.dump.InternalDumpException

Specified by:

generateDump in interface com.gigaspaces.internal.dump.InternalDumpProvider

Throws:

RemoteException

com.gigaspaces.internal.dump.InternalDumpException

deploy

public void deploy(ElasticDataGridDeployment deployment)

getManagedProcessingUnits

public String[] getManagedProcessingUnits()

Specified by:

getManagedProcessingUnits in interface com.gigaspaces.grid.esm.ESM

isServiceSecured

public boolean isServiceSecured()
                         throws RemoteException

Specified by:

isServiceSecured in interface com.gigaspaces.security.service.SecuredService

Throws:

RemoteException

login

public SecurityContext login(UserDetails userDetails)
                      throws SecurityException,
                             RemoteException

Specified by:

login in interface com.gigaspaces.security.service.SecuredService

Throws:

SecurityException

RemoteException