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

Class UnifiedReplicationRouter

java.lang.Object

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

All Implemented Interfaces:

IReplicationRouter

public class UnifiedReplicationRouter
extends Object
implements IReplicationRouter

A replication router that has both SpaceProxyReplicationRouter and LusReplicationRouter and delegate the request according to the lookup name

Since:

8.0.3

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UnifiedReplicationRouter.Builder

Constructor Summary

Constructors

Constructor and Description
UnifiedReplicationRouter(IReplicationRouter spaceProxyReplicationRouter, IReplicationRouter lusReplicationRouter)

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UnifiedReplicationRouter

public UnifiedReplicationRouter(IReplicationRouter spaceProxyReplicationRouter,
                                IReplicationRouter lusReplicationRouter)

Method Detail

getMemberConnectionAsync

public IReplicationMonitoredConnection getMemberConnectionAsync(String memberLookupName)

Description copied from interface: IReplicationRouter

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

Specified by:

getMemberConnectionAsync in interface IReplicationRouter

Parameters:

memberLookupName - the replication node name to create the connection to

Returns:

a connection to the specified replication node

getMemberConnection

public IReplicationMonitoredConnection getMemberConnection(String memberLookupName)

Description copied from interface: IReplicationRouter

Create new replication connection and establishes it.

Specified by:

getMemberConnection in interface IReplicationRouter

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

getDirectConnection

public IReplicationMonitoredConnection getDirectConnection(RouterStubHolder remoteStubHolder)

Description copied from interface: IReplicationRouter

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

Specified by:

getDirectConnection in interface IReplicationRouter

Parameters:

remoteStubHolder - the target router of the connection

Returns:

a connection to the specified router

close

public void close()

Specified by:

close in interface IReplicationRouter

getMyLookupName

public String getMyLookupName()

Specified by:

getMyLookupName in interface IReplicationRouter

getMyUniqueId

public Object getMyUniqueId()

Specified by:

getMyUniqueId in interface IReplicationRouter

getMyStubHolder

public RouterStubHolder getMyStubHolder()

Description copied from interface: IReplicationRouter

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

Specified by:

getMyStubHolder in interface IReplicationRouter

See Also:

IReplicationRouter.getDirectConnection(RouterStubHolder)

getMyEndpointDetails

public ReplicationEndpointDetails getMyEndpointDetails()

Description copied from interface: IReplicationRouter

Gets this router endpoint details

Specified by:

getMyEndpointDetails in interface IReplicationRouter

getAdmin

public IReplicationRouterAdmin getAdmin()

Specified by:

getAdmin in interface IReplicationRouter

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationRouter