Modifier and Type | Method and Description |
---|---|
protected AbstractProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
LusReplicationRouter.createNewMemberConnection(String lookupName,
boolean connectSynchronously) |
Modifier and Type | Method and Description |
---|---|
protected Runnable |
LusScheduledPoolConnectionMonitor.createMonitorDisconnectedTask(AbstractProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> connection) |
Modifier and Type | Class and Description |
---|---|
class |
MemberProxyBasedReplicationMonitoredConnection<T,L> |
class |
StubBasedReplicationMonitoredConnection |
class |
UrlProxyBasedReplicationMonitoredConnection<T,L> |
Modifier and Type | Method and Description |
---|---|
protected abstract AbstractProxyBasedReplicationMonitoredConnection<T,L> |
AbstractConnectionProxyBasedReplicationRouter.createNewMemberConnection(String lookupName,
boolean connectSynchronously) |
protected AbstractProxyBasedReplicationMonitoredConnection |
DirectOnlyReplicationRouter.createNewMemberConnection(String lookupName,
boolean connectSynchronously) |
protected AbstractProxyBasedReplicationMonitoredConnection<IReplicationConnectionProxy,Object> |
AbstractConnectionProxyBasedReplicationRouter.wrapDirectStubWithMonitoredConnection(boolean connectSynchronously,
RouterStubHolder routerStubHolder) |
Constructor and Description |
---|
MonitorConnectedConnectionTask(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection) |
Modifier and Type | Method and Description |
---|---|
protected AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> |
SpaceProxyReplicationRouter.createNewMemberConnection(String lookupName,
boolean connectSynchronously) |
AbstractProxyBasedReplicationMonitoredConnection<T,L> |
ConnectionReference.getUnderlyingConnection() |
Modifier and Type | Method and Description |
---|---|
void |
IConnectionMonitor.monitor(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection)
Adds a new connection to monitor
|
void |
IConnectionMonitor.stopMonitoring(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection)
Stops monitoring the specified connection
|
void |
IConnectionMonitor.updateDisconnected(AbstractProxyBasedReplicationMonitoredConnection<T,L> 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
|
Constructor and Description |
---|
ConnectionReference(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection) |
Modifier and Type | Method and Description |
---|---|
void |
FailureDetectorConnectionMonitor.monitor(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection) |
void |
FailureDetectorConnectionMonitor.stopMonitoring(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection) |
void |
FailureDetectorConnectionMonitor.updateDisconnected(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection,
Exception reason) |
Constructor and Description |
---|
MonitorDisconnectedConnectionTask(AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> connection,
FailureDetectorConnectionMonitor monitor) |
Copyright © GigaSpaces.