Package com.gigaspaces.cluster.activeelection.core

Class ActiveFailureDetector

java.lang.Object

java.lang.Thread

com.gigaspaces.internal.utils.concurrent.GSThread

com.gigaspaces.cluster.activeelection.core.ActiveFailureDetector

All Implemented Interfaces:

FaultDetectionListener, Runnable

public class ActiveFailureDetector
extends GSThread
implements FaultDetectionListener

Provides a failure detection on active service. On active failure elect the new active. On elect the ActiveFailureDetector terminates all functionality.

Since:

6.0

Version:

1.0

Author:

Igor Goldenberg

See Also:

• ActiveElectionManager

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method	Description
boolean	isTerminate()
void	run()
void	serviceFailure(Object service, Object serviceID)	Notify the FaultDetectionListener that the service has failed
void	terminate()	Terminate the ActiveFailureDetector.
String	toString()

Methods inherited from class com.gigaspaces.internal.utils.concurrent.GSThread

daemon

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Method Details

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

See Also:

• FaultDetectionListener.serviceFailure(Object, Object)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

isTerminate

public boolean isTerminate()

Returns:

if failure detector should be terminated

terminate

public void terminate()

Terminate the ActiveFailureDetector.

toString

public String toString()

Overrides:

toString in class Thread