com.gigaspaces.cluster

Class ClusterFailureDetector

java.lang.Object

com.gigaspaces.cluster.ClusterFailureDetector

All Implemented Interfaces:

IFailureDetector, FaultDetectionListener

public class ClusterFailureDetector
extends Object
implements FaultDetectionListener, IFailureDetector

Monitors cluster members proxies and detects proxy disconnections. Once proxy was disconnected it is removed from monitoring. When disconnected member reconnects it will be re-registered as a new service.

Since:

7.0

Author:

anna

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_INVOCATION_DELAY
static int	DEFAULT_RETRY_COUNT
static long	DEFAULT_RETRY_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
ClusterFailureDetector()
ClusterFailureDetector(String[] config)

Method Summary

Modifier and Type	Method and Description
void	register(FaultDetectionListener listener, ServiceID serviceId, Object service)
void	registerRemoteSpace(FaultDetectionListener listener, ServiceID serviceId, IRemoteSpace spaceProxy)
void	serviceFailure(Object service, Object serviceID) Notify the FaultDetectionListener that the service has failed
void	terminate()

Methods inherited from class java.lang.Object

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

Field Detail

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

DEFAULT_INVOCATION_DELAY

public static final long DEFAULT_INVOCATION_DELAY

See Also:

Constant Field Values

Constructor Detail

ClusterFailureDetector

public ClusterFailureDetector()

ClusterFailureDetector

public ClusterFailureDetector(String[] config)

Method Detail

registerRemoteSpace

public void registerRemoteSpace(FaultDetectionListener listener,
                                ServiceID serviceId,
                                IRemoteSpace spaceProxy)
                         throws Exception

Specified by:

registerRemoteSpace in interface IFailureDetector

Throws:

Exception

register

public void register(FaultDetectionListener listener,
                     ServiceID serviceId,
                     Object service)
              throws Exception

Throws:

Exception

serviceFailure

public void serviceFailure(Object service,
                           Object serviceID)

Description copied from interface: FaultDetectionListener

Notify the FaultDetectionListener that the service has failed

Specified by:

serviceFailure in interface FaultDetectionListener

Parameters:

service - The service that has failed

serviceID - An Object representing a unique service identifier of the service that has failed

terminate

public void terminate()