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

Interface IReplicationRouter

All Known Implementing Classes:

AbstractConnectionProxyBasedReplicationRouter, DirectOnlyReplicationRouter, LocalClusterReplicationSinkRouter, LusReplicationRouter, SpaceProxyReplicationRouter, UnifiedReplicationRouter

public interface IReplicationRouter

provides outgoing IReplicationMonitoredConnection and in charge of keeping it connected.

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method and Description
void	close()
String	dumpState()
IReplicationRouterAdmin	getAdmin()
IReplicationMonitoredConnection	getDirectConnection(RouterStubHolder remoteStubHolder) Gets a direct connection to the router represented by the given stub.
IReplicationMonitoredConnection	getMemberConnection(String memberLookupName) Create new replication connection and establishes it.
IReplicationMonitoredConnection	getMemberConnectionAsync(String memberLookupName) Gets a replication connection to a designated replication node by its name, the received connection is automatically managed by the router and it is in charge of detecting disconnection and reestablish connection when available.
ReplicationEndpointDetails	getMyEndpointDetails() Gets this router endpoint details
String	getMyLookupName()
RouterStubHolder	getMyStubHolder() Gets a stub holder for the current router, that a remote router can use to create a connection to this router
Object	getMyUniqueId()
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

Method Detail

getMemberConnectionAsync

IReplicationMonitoredConnection getMemberConnectionAsync(String memberLookupName)

Gets a replication connection to a designated replication node by its name, the received connection is automatically managed by the router and it is in charge of detecting disconnection and reestablish connection when available. Connection is established asynchronously

Parameters:

memberLookupName - the replication node name to create the connection to

Returns:

a connection to the specified replication node

getMemberConnection

IReplicationMonitoredConnection getMemberConnection(String memberLookupName)

Create new replication connection and establishes it.

getUrlConnection

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

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

getDirectConnection

IReplicationMonitoredConnection getDirectConnection(RouterStubHolder remoteStubHolder)

Gets a direct connection to the router represented by the given stub.

Parameters:

remoteStubHolder - the target router of the connection

Returns:

a connection to the specified router

close

void close()

getMyLookupName

String getMyLookupName()

getMyUniqueId

Object getMyUniqueId()

getMyStubHolder

RouterStubHolder getMyStubHolder()

Gets a stub holder for the current router, that a remote router can use to create a connection to this router

See Also:

getDirectConnection(RouterStubHolder)

dumpState

String dumpState()

getAdmin

IReplicationRouterAdmin getAdmin()

getMyEndpointDetails

ReplicationEndpointDetails getMyEndpointDetails()

Gets this router endpoint details