com.gigaspaces.internal.cluster.node.impl.router.spacefinder.failuredetector

Class FailureDetectorConnectionMonitor

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.router.spacefinder.failuredetector.FailureDetectorConnectionMonitor

All Implemented Interfaces:

IConnectionMonitor<IRemoteSpace,SpaceURL>, FaultDetectionListener

public class FailureDetectorConnectionMonitor
extends Object
implements IConnectionMonitor<IRemoteSpace,SpaceURL>, FaultDetectionListener

A ClusterFailureDetector based implementation of the IConnectionMonitor interface. Used an internal pool to monitor dead connections and the ClusterFailureDetector to detect live connections failure

Since:

8.0

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	FailureDetectorConnectionMonitor.MonitorDisconnectedConnectionTask

Constructor Summary

Constructors

Constructor and Description
FailureDetectorConnectionMonitor(String myLookupName, int corePoolSize, long monitorDisconnectedDelay, TimeUnit timeUnit, ISpaceProxyProvider proxyProvider, IFailureDetector failureDetector)

Method Summary

Modifier and Type	Method and Description
void	close()
String	dumpState()
int	getMonitoredCount()
void	monitor(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection) Adds a new connection to monitor
void	serviceFailure(Object service, Object serviceID) Notify the FaultDetectionListener that the service has failed
void	stopMonitoring(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection) Stops monitoring the specified connection
void	updateDisconnected(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection, Exception reason) Update the monitor externally that the provided connection is disconnected Due to some call dispatch on that proxy which throw a remote exception

Methods inherited from class java.lang.Object

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

Constructor Detail

FailureDetectorConnectionMonitor

public FailureDetectorConnectionMonitor(String myLookupName,
                                        int corePoolSize,
                                        long monitorDisconnectedDelay,
                                        TimeUnit timeUnit,
                                        ISpaceProxyProvider proxyProvider,
                                        IFailureDetector failureDetector)

Method Detail

monitor

public void monitor(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection)

Description copied from interface: IConnectionMonitor

Adds a new connection to monitor

Specified by:

monitor in interface IConnectionMonitor<IRemoteSpace,SpaceURL>

Parameters:

connection - connection to monitor

stopMonitoring

public void stopMonitoring(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection)

Description copied from interface: IConnectionMonitor

Stops monitoring the specified connection

Specified by:

stopMonitoring in interface IConnectionMonitor<IRemoteSpace,SpaceURL>

Parameters:

connection - that should be not be monitored anymore

updateDisconnected

public void updateDisconnected(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection,
                               Exception reason)

Description copied from interface: IConnectionMonitor

Update the monitor externally that the provided connection is disconnected Due to some call dispatch on that proxy which throw a remote exception

Specified by:

updateDisconnected in interface IConnectionMonitor<IRemoteSpace,SpaceURL>

Parameters:

connection - connection that was disconnected

getMonitoredCount

public int getMonitoredCount()

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

close

public void close()

Specified by:

close in interface IConnectionMonitor<IRemoteSpace,SpaceURL>

dumpState

public String dumpState()

Specified by:

dumpState in interface IConnectionMonitor<IRemoteSpace,SpaceURL>