Package com.gigaspaces.internal.cluster.node.impl.router.spacefinder

Class SpaceProxyReplicationRouter

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.router.AbstractConnectionProxyBasedReplicationRouter<IRemoteSpace,SpaceURL>

com.gigaspaces.internal.cluster.node.impl.router.spacefinder.SpaceProxyReplicationRouter

All Implemented Interfaces:

IReplicationRouter, IReplicationRouterAdmin

public class SpaceProxyReplicationRouter
extends AbstractConnectionProxyBasedReplicationRouter<IRemoteSpace,SpaceURL>
implements IReplicationRouter

An implementation of the IReplicationRouter interface that uses a space proxy to locate a replication connection proxy as its communication facade

Since:

8.0

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SpaceProxyReplicationRouter.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.router.AbstractConnectionProxyBasedReplicationRouter

_specificLogger

Constructor Summary

Constructors

Constructor	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)

Method Summary

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

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

SpaceProxyReplicationRouter

public SpaceProxyReplicationRouter(String myLookupName,
 Uuid uuid,
 IConnectionMonitor<IRemoteSpace,SpaceURL> connectionMonitor,
 IServiceExporter serviceExporter,
 IIncomingReplicationHandler incomingReplicationHandler,
 ISpaceProxyProvider spaceProxyProvider,
 ISpaceUrlConverter spaceUrlConverter,
 int replicationMonitorThreadPoolSize)

SpaceProxyReplicationRouter

public SpaceProxyReplicationRouter(String myLookupName,
 Uuid uuid,
 IConnectionMonitor<IRemoteSpace,SpaceURL> connectionMonitor,
 IServiceExporter serviceExporter,
 IIncomingReplicationHandler incomingReplicationHandler,
 ISpaceProxyProvider spaceProxyProvider,
 ISpaceUrlConverter spaceUrlConverter)

Method Details

createNewMemberConnection

protected AbstractProxyBasedReplicationMonitoredConnection<IRemoteSpace,SpaceURL> createNewMemberConnection(String lookupName,
 boolean connectSynchronously)

Specified by:

createNewMemberConnection in class AbstractConnectionProxyBasedReplicationRouter<IRemoteSpace,SpaceURL>

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