public class LocalClusterReplicationSinkRouter extends LusReplicationRouter
LocalClusterReplicationSink that can
create a replication connection from one sink via another sink to a specific space member| Modifier and Type | Class and Description |
|---|---|
static class |
LocalClusterReplicationSinkRouter.Builder |
AbstractConnectionProxyBasedReplicationRouter.ConnectionEndpoint_replicationLookupService_specificLogger| Constructor and Description |
|---|
LocalClusterReplicationSinkRouter(String myLookupName,
Uuid uuid,
IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor,
IIncomingReplicationHandler incomingReplicationHandler,
IReplicationLookupFinderService replicationLookupService,
IReplicationLookupParameters lookupParametersTemplate,
IRoutingUrlConverter routingNameConverter) |
| Modifier and Type | Method and Description |
|---|---|
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
createConnectionAndConnect(String lookupName,
Iterable<IReplicationLookupParameters> lookupParametersList) |
protected IReplicationLookupResult |
establishConnectionViaSink(IReplicationConnectionProxy connectionProxy,
String lookupName) |
static String |
extractSinkDestinationUrl(String lookupName) |
static String |
extractSpaceMemberLookupName(String lookupName) |
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
|
static boolean |
hasSinkRoutingDestination(String lookupName) |
createConnection, createNewMemberConnectionaddRemoteRouterStub, 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 LocalClusterReplicationSinkRouter(String myLookupName, Uuid uuid, IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor, IIncomingReplicationHandler incomingReplicationHandler, IReplicationLookupFinderService replicationLookupService, IReplicationLookupParameters lookupParametersTemplate, IRoutingUrlConverter routingNameConverter)
public IReplicationMonitoredConnection getUrlConnection(Object customUrl)
IReplicationRoutergetUrlConnection in interface IReplicationRoutergetUrlConnection in class LusReplicationRoutercustomUrl - the url to the replication node to create the connection toprotected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> createConnectionAndConnect(String lookupName, Iterable<IReplicationLookupParameters> lookupParametersList)
createConnectionAndConnect in class LusReplicationRouterprotected IReplicationLookupResult establishConnectionViaSink(IReplicationConnectionProxy connectionProxy, String lookupName) throws RemoteException
RemoteExceptionpublic static boolean hasSinkRoutingDestination(String lookupName)
Copyright © GigaSpaces.