com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class LocalClusterReplicationScheduledPoolConnectionMonitor

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.router.AbstractScheduledPoolConnectionMonitor<Iterable<IReplicationLookupParameters>,String>

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

com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationScheduledPoolConnectionMonitor

All Implemented Interfaces:

IConnectionMonitor<Iterable<IReplicationLookupParameters>,String>

public class LocalClusterReplicationScheduledPoolConnectionMonitor
extends LusScheduledPoolConnectionMonitor

Since:

8.0.3

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
LocalClusterReplicationScheduledPoolConnectionMonitor(String myLookupName, int corePoolSize, long monitorConnectedDelay, long monitorDisconnectedDelay, TimeUnit timeUnit, IReplicationLookupFinderService replicationLookupService)

Method Summary

Modifier and Type	Method and Description
protected IReplicationLookupResult	postConnectionEstablished(IReplicationLookupResult lookupResult, IReplicationLookupParameters lookupParameters, IReplicationRouter router)
protected IReplicationLookupParameters	prepareLookUpParameters(IReplicationLookupParameters lookupParameters)

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

createMonitorDisconnectedTask

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

LocalClusterReplicationScheduledPoolConnectionMonitor

public LocalClusterReplicationScheduledPoolConnectionMonitor(String myLookupName,
                                                             int corePoolSize,
                                                             long monitorConnectedDelay,
                                                             long monitorDisconnectedDelay,
                                                             TimeUnit timeUnit,
                                                             IReplicationLookupFinderService replicationLookupService)

Method Detail

prepareLookUpParameters

protected IReplicationLookupParameters prepareLookUpParameters(IReplicationLookupParameters lookupParameters)

Overrides:

prepareLookUpParameters in class LusScheduledPoolConnectionMonitor

postConnectionEstablished

protected IReplicationLookupResult postConnectionEstablished(IReplicationLookupResult lookupResult,
                                                             IReplicationLookupParameters lookupParameters,
                                                             IReplicationRouter router)
                                                      throws RemoteException

Overrides:

postConnectionEstablished in class LusScheduledPoolConnectionMonitor

Throws:

RemoteException