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

Class DirectConnectionScheduledPoolConnectionMonitor

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor<IReplicationConnectionProxy,Object>

com.gigaspaces.internal.cluster.node.impl.router.DirectConnectionScheduledPoolConnectionMonitor

All Implemented Interfaces:

IConnectionMonitor<IReplicationConnectionProxy,Object>

public class DirectConnectionScheduledPoolConnectionMonitor
extends AbstractScheduledPoolConnectionMonitor<IReplicationConnectionProxy,Object>

A replication connection monitors for connection that are established with a direct connection proxy. Such connection can only reestablish a connection using the same stub it was initially used for creation, this means no failover is supported for such connections IReplicationConnectionProxy

Since:

8.0.5

Author:

eitany

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor

AbstractScheduledPoolConnectionMonitor.MonitorConnectedConnectionTask

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor

_specificLogger

Constructor Summary

Constructors

Constructor and Description
DirectConnectionScheduledPoolConnectionMonitor(String myLookupName, int corePoolSize, long monitorConnectedDelay, long monitorDisconnectedDelay, TimeUnit timeUnit)

Method Summary

Modifier and Type	Method and Description
protected Runnable	createMonitorDisconnectedTask(AbstractProxyBasedReplicationMonitoredConnection<IReplicationConnectionProxy,Object> connection)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor

close, dumpState, getLogPrefix, getMonitoredCount, monitor, stopMonitoring, updateDisconnected

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectConnectionScheduledPoolConnectionMonitor

public DirectConnectionScheduledPoolConnectionMonitor(String myLookupName,
                                                      int corePoolSize,
                                                      long monitorConnectedDelay,
                                                      long monitorDisconnectedDelay,
                                                      TimeUnit timeUnit)

Method Detail

createMonitorDisconnectedTask

protected Runnable createMonitorDisconnectedTask(AbstractProxyBasedReplicationMonitoredConnection<IReplicationConnectionProxy,Object> connection)

Specified by:

createMonitorDisconnectedTask in class AbstractScheduledPoolConnectionMonitor<IReplicationConnectionProxy,Object>