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

Class LusReplicationRouter

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationRouter, IReplicationRouterAdmin

Direct Known Subclasses:

LocalClusterReplicationSinkRouter

public class LusReplicationRouter
extends AbstractConnectionProxyBasedReplicationRouter<Iterable<IReplicationLookupParameters>,String>
implements IReplicationRouter

A replication router that uses a look up service in order to find replication connection proxies

Since:

8.0.3

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LusReplicationRouter.Builder

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

AbstractConnectionProxyBasedReplicationRouter.ConnectionEndpoint

Field Summary

Fields

Modifier and Type	Field and Description
protected IReplicationLookupFinderService	_replicationLookupService

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

_specificLogger

Constructor Summary

Constructors

Constructor and Description

LusReplicationRouter(String myLookupName, Uuid uuid, IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor, IServiceExporter serviceExporter, IIncomingReplicationHandler incomingReplicationHandler, IAsyncContextProvider asyncContextProvider, IReplicationLookupFinderService replicationLookupService, IReplicationLookupParameters lookupParametersTemplate, IRoutingUrlConverter routingNameConverter, boolean setMyIdBeforeDispatch)

Method Summary

Modifier and Type	Method and Description
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String>	createConnection(String lookupName, Iterable<IReplicationLookupParameters> lookupParameters)
protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String>	createConnectionAndConnect(String lookupName, Iterable<IReplicationLookupParameters> lookupParametersList)
protected AbstractProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String>	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

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

Field Detail

_replicationLookupService

protected final IReplicationLookupFinderService _replicationLookupService

Constructor Detail

LusReplicationRouter

public LusReplicationRouter(String myLookupName,
                            Uuid uuid,
                            IConnectionMonitor<Iterable<IReplicationLookupParameters>,String> connectionMonitor,
                            IServiceExporter serviceExporter,
                            IIncomingReplicationHandler incomingReplicationHandler,
                            IAsyncContextProvider asyncContextProvider,
                            IReplicationLookupFinderService replicationLookupService,
                            IReplicationLookupParameters lookupParametersTemplate,
                            IRoutingUrlConverter routingNameConverter,
                            boolean setMyIdBeforeDispatch)

Method Detail

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

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

createNewMemberConnection

protected AbstractProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> createNewMemberConnection(String lookupName,
                                                                                                                                    boolean connectSynchronously)

Specified by:

createNewMemberConnection in class AbstractConnectionProxyBasedReplicationRouter<Iterable<IReplicationLookupParameters>,String>

createConnection

protected MemberProxyBasedReplicationMonitoredConnection<Iterable<IReplicationLookupParameters>,String> createConnection(String lookupName,
                                                                                                                         Iterable<IReplicationLookupParameters> lookupParameters)

createConnectionAndConnect

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