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

Class LocalClusterReplicationSinkRouter

java.lang.Object

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

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

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

All Implemented Interfaces:

IReplicationRouter, IReplicationRouterAdmin

public class LocalClusterReplicationSinkRouter
extends LusReplicationRouter

Special replication router that exists inside a LocalClusterReplicationSink that can create a replication connection from one sink via another sink to a specific space member

Since:

8.0.3

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LocalClusterReplicationSinkRouter.Builder

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractConnectionProxyBasedReplicationRouter

AbstractConnectionProxyBasedReplicationRouter.ConnectionEndpoint

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.router.LusReplicationRouter

_replicationLookupService

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.router.AbstractConnectionProxyBasedReplicationRouter

_specificLogger

Constructor Summary

Constructors

Constructor	Description
LocalClusterReplicationSinkRouter(String myLookupName, Uuid uuid, IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor, IIncomingReplicationHandler incomingReplicationHandler, IReplicationLookupFinderService replicationLookupService, IReplicationLookupParameters lookupParametersTemplate, IRoutingUrlConverter routingNameConverter)

Method Summary

Modifier and Type	Method	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)

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

createConnection, createNewMemberConnection

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

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, wrapDirectStubWithMonitoredConnection

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.router.IReplicationRouter

close, dumpState, getAdmin, getDirectConnection, getMemberConnection, getMemberConnectionAsync, getMyEndpointDetails, getMyLookupName, getMyStubHolder, getMyUniqueId

Constructor Details

LocalClusterReplicationSinkRouter

public LocalClusterReplicationSinkRouter(String myLookupName,
 Uuid uuid,
 IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor,
 IIncomingReplicationHandler incomingReplicationHandler,
 IReplicationLookupFinderService replicationLookupService,
 IReplicationLookupParameters lookupParametersTemplate,
 IRoutingUrlConverter routingNameConverter)

Method Details

getUrlConnection

public IReplicationMonitoredConnection getUrlConnection(Object customUrl)

Description copied from interface: IReplicationRouter

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

Specified by:

getUrlConnection in interface IReplicationRouter

Overrides:

getUrlConnection in class LusReplicationRouter

Parameters:

customUrl - the url to the replication node to create the connection to

Returns:

a connection to the specified replication node represented by the url

createConnectionAndConnect

protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> createConnectionAndConnect(String lookupName,
 Iterable<IReplicationLookupParameters> lookupParametersList)

Overrides:

createConnectionAndConnect in class LusReplicationRouter

establishConnectionViaSink

protected IReplicationLookupResult establishConnectionViaSink(IReplicationConnectionProxy connectionProxy,
 String lookupName)
                                                       throws RemoteException

Throws:

RemoteException

extractSpaceMemberLookupName

public static String extractSpaceMemberLookupName(String lookupName)

hasSinkRoutingDestination

public static boolean hasSinkRoutingDestination(String lookupName)

extractSinkDestinationUrl

public static String extractSinkDestinationUrl(String lookupName)