public class SpaceProxyReplicationRouter extends AbstractConnectionProxyBasedReplicationRouter<IRemoteSpace,SpaceURL> implements IReplicationRouter
IReplicationRouter interface that uses a space proxy to locate a
replication connection proxy as its communication facade| Modifier and Type | Class and Description |
|---|---|
static class |
SpaceProxyReplicationRouter.Builder |
AbstractConnectionProxyBasedReplicationRouter.ConnectionEndpoint_specificLogger| Constructor and Description |
|---|
SpaceProxyReplicationRouter(String myLookupName,
Uuid uuid,
IConnectionMonitor<IRemoteSpace,SpaceURL> connectionMonitor,
IServiceExporter serviceExporter,
IIncomingReplicationHandler incomingReplicationHandler,
ISpaceProxyProvider spaceProxyProvider,
ISpaceUrlConverter spaceUrlConverter) |
SpaceProxyReplicationRouter(String myLookupName,
Uuid uuid,
IConnectionMonitor<IRemoteSpace,SpaceURL> connectionMonitor,
IServiceExporter serviceExporter,
IIncomingReplicationHandler incomingReplicationHandler,
ISpaceProxyProvider spaceProxyProvider,
ISpaceUrlConverter spaceUrlConverter,
int replicationMonitorThreadPoolSize) |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> |
createNewMemberConnection(String lookupName,
boolean connectSynchronously) |
IReplicationMonitoredConnection |
getUrlConnection(Object customUrl)
Gets a connection with given custom url, need to have this due to space copy with given url
which may not even reside in the cluster policy and for sink recovery
|
addRemoteRouterStub, close, createDirectConnection, createStub, dumpState, enableIncomingCommunication, getAdmin, getAsyncContextProvider, getConnectionMonitor, getDirectConnection, getMemberConnection, getMemberConnectionAsync, getMyEndpointDetails, getMyLookupName, getMyRouterStubHolder, getMyStubHolder, getMyUniqueId, getRemoteRouterStub, getStub, hasExistingConnection, isClosed, isSetMyIdBeforeDispatch, pingStub, removeDirectConnection, removeMemberConnection, removeRemoteStubHolder, removeUrlConnection, wrapDirectStubWithMonitoredConnectionclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclose, dumpState, getAdmin, getDirectConnection, getMemberConnection, getMemberConnectionAsync, getMyEndpointDetails, getMyLookupName, getMyStubHolder, getMyUniqueIdpublic SpaceProxyReplicationRouter(String myLookupName, Uuid uuid, IConnectionMonitor<IRemoteSpace,SpaceURL> connectionMonitor, IServiceExporter serviceExporter, IIncomingReplicationHandler incomingReplicationHandler, ISpaceProxyProvider spaceProxyProvider, ISpaceUrlConverter spaceUrlConverter, int replicationMonitorThreadPoolSize)
public SpaceProxyReplicationRouter(String myLookupName, Uuid uuid, IConnectionMonitor<IRemoteSpace,SpaceURL> connectionMonitor, IServiceExporter serviceExporter, IIncomingReplicationHandler incomingReplicationHandler, ISpaceProxyProvider spaceProxyProvider, ISpaceUrlConverter spaceUrlConverter)
protected AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> createNewMemberConnection(String lookupName, boolean connectSynchronously)
createNewMemberConnection in class AbstractConnectionProxyBasedReplicationRouter<IRemoteSpace,SpaceURL>public IReplicationMonitoredConnection getUrlConnection(Object customUrl)
IReplicationRoutergetUrlConnection in interface IReplicationRoutercustomUrl - the url to the replication node to create the connection toCopyright © GigaSpaces.