Package 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 Details

    • 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:

    • dumpState

      String dumpState()

    • getAdmin

      IReplicationRouterAdmin getAdmin()

    • getMyEndpointDetails

      ReplicationEndpointDetails getMyEndpointDetails()
      Gets this router endpoint details