Constructor and Description |
---|
ReplicationConnectionDelegator(String mySiteName,
String targetLookupName,
String routingLookupName,
IReplicationLookupFinderService finderService,
IReplicationLookupRegistrationService registrationService,
IReplicationLookupParameters lookupParametersTemplate,
IReplicationLookupParameters registrationParameters,
IServiceExporter serviceExporter) |
Modifier and Type | Class and Description |
---|---|
class |
ReplicationLookupParameters |
Modifier and Type | Method and Description |
---|---|
IReplicationLookupParameters |
IReplicationLookupParameters.clone() |
IReplicationLookupParameters |
ReplicationLookupParameters.clone() |
IReplicationLookupParameters |
LusExportedReplicationComponent.getMyRegistrationParameters() |
IReplicationLookupParameters |
IReplicationLookupParameters.merge(IReplicationLookupParameters other) |
Modifier and Type | Method and Description |
---|---|
IReplicationLookupResult |
IReplicationLookupFinderService.findConnectionProxy(IReplicationLookupParameters lookupParameters) |
IReplicationLookupResult |
ReplicationLookupFinderService.findConnectionProxy(IReplicationLookupParameters lookupParameters) |
IReplicationLookupParameters |
IReplicationLookupParameters.merge(IReplicationLookupParameters other) |
ReplicationLookupParameters |
ReplicationLookupParameters.merge(IReplicationLookupParameters other) |
void |
IReplicationLookupRegistrationService.registerConnectionProxy(IReplicationLookupParameters registerationLookupParameters,
IReplicationConnectionProxy connectionProxy,
IReplicationLookupRegistrationListener registrationListener,
Uuid serviceUuid)
Starts registration process of the specified replication connection proxy, The listener can
be provided to be notified once registration is successful.
|
void |
ReplicationLookupRegistrationService.registerConnectionProxy(IReplicationLookupParameters lookupParameters,
IReplicationConnectionProxy connectionProxy,
IReplicationLookupRegistrationListener registrationListener,
Uuid serviceUuid) |
void |
IReplicationLookupRegistrationService.unregisterConnectionProxy(IReplicationLookupParameters registerationLookupParameters)
Unregisters an already registered replication connection proxy.
|
void |
ReplicationLookupRegistrationService.unregisterConnectionProxy(IReplicationLookupParameters registerationLookupParameters) |
Constructor and Description |
---|
LusExportedReplicationComponent(String myLookupName,
String mySiteName,
IServiceExporter serviceExporter,
IReplicationLookupRegistrationService lookupService,
IReplicationLookupParameters lookupParametersTemplate) |
Modifier and Type | Method and Description |
---|---|
protected IReplicationLookupParameters |
LusScheduledPoolConnectionMonitor.prepareLookUpParameters(IReplicationLookupParameters lookupParameters) |
Modifier and Type | Method and Description |
---|---|
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
LusReplicationRouter.createConnection(String lookupName,
Iterable<IReplicationLookupParameters> lookupParameters) |
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
LusReplicationRouter.createConnectionAndConnect(String lookupName,
Iterable<IReplicationLookupParameters> lookupParametersList) |
protected AbstractProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
LusReplicationRouter.createNewMemberConnection(String lookupName,
boolean connectSynchronously) |
Modifier and Type | Method and Description |
---|---|
protected IReplicationLookupResult |
LusScheduledPoolConnectionMonitor.postConnectionEstablished(IReplicationLookupResult lookupResult,
IReplicationLookupParameters lookupParameters,
IReplicationRouter router) |
protected IReplicationLookupParameters |
LusScheduledPoolConnectionMonitor.prepareLookUpParameters(IReplicationLookupParameters lookupParameters) |
Modifier and Type | Method and Description |
---|---|
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
LusReplicationRouter.createConnection(String lookupName,
Iterable<IReplicationLookupParameters> lookupParameters) |
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
LusReplicationRouter.createConnectionAndConnect(String lookupName,
Iterable<IReplicationLookupParameters> lookupParametersList) |
protected Runnable |
LusScheduledPoolConnectionMonitor.createMonitorDisconnectedTask(AbstractProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> connection) |
Constructor and Description |
---|
Builder(String myLookupName,
IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor,
IServiceExporter serviceExporter,
Uuid uuid,
IAsyncContextProvider asyncContextProvider,
IReplicationLookupFinderService lookupService,
IReplicationLookupParameters lookupParametersTemplate,
IRoutingUrlConverter routingUrlConverter,
boolean setMyIdBeforeDispatch) |
LusReplicationRouter(String myLookupName,
Uuid uuid,
IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor,
IServiceExporter serviceExporter,
IIncomingReplicationHandler incomingReplicationHandler,
IAsyncContextProvider asyncContextProvider,
IReplicationLookupFinderService replicationLookupService,
IReplicationLookupParameters lookupParametersTemplate,
IRoutingUrlConverter routingNameConverter,
boolean setMyIdBeforeDispatch) |
Modifier and Type | Method and Description |
---|---|
protected IReplicationLookupParameters |
LocalClusterReplicationScheduledPoolConnectionMonitor.prepareLookUpParameters(IReplicationLookupParameters lookupParameters) |
Modifier and Type | Method and Description |
---|---|
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
LocalClusterReplicationSinkRouter.createConnectionAndConnect(String lookupName,
Iterable<IReplicationLookupParameters> lookupParametersList) |
Modifier and Type | Method and Description |
---|---|
protected IReplicationLookupResult |
LocalClusterReplicationScheduledPoolConnectionMonitor.postConnectionEstablished(IReplicationLookupResult lookupResult,
IReplicationLookupParameters lookupParameters,
IReplicationRouter router) |
protected IReplicationLookupParameters |
LocalClusterReplicationScheduledPoolConnectionMonitor.prepareLookUpParameters(IReplicationLookupParameters lookupParameters) |
Modifier and Type | Method and Description |
---|---|
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> |
LocalClusterReplicationSinkRouter.createConnectionAndConnect(String lookupName,
Iterable<IReplicationLookupParameters> lookupParametersList) |
Constructor and Description |
---|
Builder(String myLookupName,
IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor,
Uuid uuid,
IReplicationLookupFinderService lookupService,
IReplicationLookupParameters lookupParametersTemplate,
IRoutingUrlConverter routingUrlConverter) |
LocalClusterReplicationSinkRouter(String myLookupName,
Uuid uuid,
IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor,
IIncomingReplicationHandler incomingReplicationHandler,
IReplicationLookupFinderService replicationLookupService,
IReplicationLookupParameters lookupParametersTemplate,
IRoutingUrlConverter routingNameConverter) |
Copyright © GigaSpaces.