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

Class DirectOnlyReplicationRouter

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationRouter, IReplicationRouterAdmin

public class DirectOnlyReplicationRouter
extends AbstractConnectionProxyBasedReplicationRouter<Object,Object>

Since:

9.0

Author:

Dan Kilman

Nested Class Summary

Nested Classes

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

Method Summary

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

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

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 createNewMemberConnection(String lookupName,
                                                                                     boolean connectSynchronously)

Specified by:

createNewMemberConnection in class AbstractConnectionProxyBasedReplicationRouter<Object,Object>