Package com.j_spaces.core.cluster.startup

Class AbstractFaultDetectionHandler

java.lang.Object

com.j_spaces.core.cluster.startup.AbstractFaultDetectionHandler

All Implemented Interfaces:

FaultDetectionHandler

Direct Known Subclasses:

GigaSpacesFaultDetectionHandler

public abstract class AbstractFaultDetectionHandler
extends Object
implements FaultDetectionHandler

The AbstractFaultDetectionHandler provides a base class which can be extended to provide concrete FaultDetectionHandler capabilities. The basic infrastructure included in the AbstractFaultDetectionHandler includes FaultDetectionListener registration and notification, a ServiceDiscoveryListener implementation Properties that will be common across all classes which extend this class are also provided:

• retryCount
• retryTimeout

See Also:

• FaultDetectionHandler
• FaultDetectionListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	AbstractFaultDetectionHandler.ServiceMonitor	Defines the semantics of an internal class which will be used in perform service-specific monitoring

Field Summary

Fields

Modifier and Type	Field	Description
protected Configuration	config	A Configuration object
protected String[]	configArgs	Configuration arguments
static final int	DEFAULT_RETRY_COUNT
static final long	DEFAULT_RETRY_TIMEOUT
protected Object	proxy	Object that can be used to communicate to the service
static final String	RETRY_COUNT_KEY
static final String	RETRY_TIMEOUT_KEY
protected int	retryCount
protected long	retryTimeout
protected AbstractFaultDetectionHandler.ServiceMonitor	serviceMonitor	Class which provides service monitoring
protected boolean	terminating	Flag to indicate the utility is terminating

Constructor Summary

Constructors

Constructor	Description
AbstractFaultDetectionHandler()

Method Summary

Modifier and Type	Method	Description
protected String	getName(Entry[] attrs)	Get the first Name.name from the attribute collection set
protected abstract void	monitor()	Get the class which implements the ServiceMonitor
void	monitor(Object proxy, ServiceID serviceID)	Begin monitoring the service
protected void	notifyListeners()	Notify FaultDetectionListener instances the service has been removed
void	register(FaultDetectionListener listener)	Register a FaultDetectionListener
void	terminate()	Terminate the FaultDetectionHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.j_spaces.core.cluster.startup.FaultDetectionHandler

setConfiguration

Field Details

DEFAULT_RETRY_COUNT

public static final int DEFAULT_RETRY_COUNT

See Also:

• Constant Field Values

DEFAULT_RETRY_TIMEOUT

public static final long DEFAULT_RETRY_TIMEOUT

See Also:

• Constant Field Values

RETRY_COUNT_KEY

public static final String RETRY_COUNT_KEY

See Also:

• Constant Field Values

RETRY_TIMEOUT_KEY

public static final String RETRY_TIMEOUT_KEY

See Also:

• Constant Field Values

proxy

protected Object proxy

Object that can be used to communicate to the service

retryCount

protected int retryCount

retryTimeout

protected long retryTimeout

terminating

protected boolean terminating

Flag to indicate the utility is terminating

configArgs

protected String[] configArgs

Configuration arguments

config

protected Configuration config

A Configuration object

serviceMonitor

protected AbstractFaultDetectionHandler.ServiceMonitor serviceMonitor

Class which provides service monitoring

Constructor Details

AbstractFaultDetectionHandler

public AbstractFaultDetectionHandler()

Method Details

register

public void register(FaultDetectionListener listener)

Description copied from interface: FaultDetectionHandler

Register a FaultDetectionListener

Specified by:

register in interface FaultDetectionHandler

Parameters:

listener - The FaultDetectionListener to register

See Also:

• FaultDetectionHandler.register(org.jini.rio.core.FaultDetectionListener)

monitor

public void monitor(Object proxy,
 ServiceID serviceID)
             throws Exception

Description copied from interface: FaultDetectionHandler

Begin monitoring the service

Specified by:

monitor in interface FaultDetectionHandler

Parameters:

proxy - The service that the FaultDetectionHandler will monitor, must not be null

serviceID - An Object representing a unique service identifier for the service being monitored, must not be null

Throws:

Exception - If there are abnormal conditions encountered

NullPointerException - if required parameters are null

See Also:

• FaultDetectionHandler.monitor(java.lang.Object, java.lang.Object, net.jini.lookup.LookupCache)

monitor

protected abstract void monitor()
                         throws Exception

Get the class which implements the ServiceMonitor

Throws:

Exception

terminate

public void terminate()

Description copied from interface: FaultDetectionHandler

Terminate the FaultDetectionHandler

Specified by:

terminate in interface FaultDetectionHandler

See Also:

• FaultDetectionHandler.terminate()

notifyListeners

protected void notifyListeners()

Notify FaultDetectionListener instances the service has been removed

getName

protected String getName(Entry[] attrs)

Get the first Name.name from the attribute collection set