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

Class AbstractConnectionProxyBasedReplicationRouter<T,L>

java.lang.Object

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

All Implemented Interfaces:

IReplicationRouter, IReplicationRouterAdmin

Direct Known Subclasses:

DirectOnlyReplicationRouter, LusReplicationRouter, SpaceProxyReplicationRouter

public abstract class AbstractConnectionProxyBasedReplicationRouter<T,L>
extends Object
implements IReplicationRouter, IReplicationRouterAdmin

A base class for replication routers that are using IReplicationConnectionProxy to communicate with each other.

Since:

8.0.3

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	AbstractConnectionProxyBasedReplicationRouter.ConnectionEndpoint

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.slf4j.Logger	_specificLogger

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractConnectionProxyBasedReplicationRouter(String myLookupName, Uuid uuid, IConnectionMonitor<T,L> connectionMonitor, IServiceExporter serviceExporter, IIncomingReplicationHandler incomingReplicationHandler, IAsyncContextProvider asyncContextProvider, boolean setMyIdBeforeDispatch)
protected	AbstractConnectionProxyBasedReplicationRouter(String myLookupName, Uuid uuid, IConnectionMonitor<T,L> connectionMonitor, IServiceExporter serviceExporter, IIncomingReplicationHandler incomingReplicationHandler, IAsyncContextProvider asyncContextProvider, boolean setMyIdBeforeDispatch, int replicationMonitorThreadPoolSize)

Method Summary

Modifier and Type	Method	Description
void	addRemoteRouterStub(RouterStubHolder routerStubHolder)
void	close()
protected IReplicationMonitoredConnection	createDirectConnection(String lookupName, boolean connectSynchronously)
protected abstract AbstractProxyBasedReplicationMonitoredConnection<T,L>	createNewMemberConnection(String lookupName, boolean connectSynchronously)
IReplicationConnectionProxy	createStub()
String	dumpState()
void	enableIncomingCommunication()
IReplicationRouterAdmin	getAdmin()
IAsyncContextProvider	getAsyncContextProvider()
protected IConnectionMonitor<T,L>	getConnectionMonitor()
IReplicationMonitoredConnection	getDirectConnection(RouterStubHolder remoteStubHolder)	Gets a direct connection to the router represented by the given stub.
IReplicationMonitoredConnection	getMemberConnection(String lookupName)	Create new replication connection and establishes it.
IReplicationMonitoredConnection	getMemberConnectionAsync(String lookupName)	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	getMyRouterStubHolder()
RouterStubHolder	getMyStubHolder()	Gets a stub holder for the current router, that a remote router can use to create a connection to this router
Uuid	getMyUniqueId()
RouterStubHolder	getRemoteRouterStub(String routerLookupName)
IReplicationConnectionProxy	getStub()
boolean	hasExistingConnection(String lookupName)
boolean	isClosed()
boolean	isSetMyIdBeforeDispatch()
void	pingStub(IReplicationConnectionProxy proxy)
void	removeDirectConnection(StubBasedReplicationMonitoredConnection connection)
void	removeMemberConnection(MemberProxyBasedReplicationMonitoredConnection<T,L> connection)
void	removeRemoteStubHolder(String routerLookupName)
void	removeUrlConnection(UrlProxyBasedReplicationMonitoredConnection<T,L> connection)
protected AbstractProxyBasedReplicationMonitoredConnection<IReplicationConnectionProxy,Object>	wrapDirectStubWithMonitoredConnection(boolean connectSynchronously, RouterStubHolder routerStubHolder)

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

getUrlConnection

Field Details

_specificLogger

protected final org.slf4j.Logger _specificLogger

Constructor Details

AbstractConnectionProxyBasedReplicationRouter

protected AbstractConnectionProxyBasedReplicationRouter(String myLookupName,
 Uuid uuid,
 IConnectionMonitor<T,L> connectionMonitor,
 IServiceExporter serviceExporter,
 IIncomingReplicationHandler incomingReplicationHandler,
 IAsyncContextProvider asyncContextProvider,
 boolean setMyIdBeforeDispatch,
 int replicationMonitorThreadPoolSize)

AbstractConnectionProxyBasedReplicationRouter

protected AbstractConnectionProxyBasedReplicationRouter(String myLookupName,
 Uuid uuid,
 IConnectionMonitor<T,L> connectionMonitor,
 IServiceExporter serviceExporter,
 IIncomingReplicationHandler incomingReplicationHandler,
 IAsyncContextProvider asyncContextProvider,
 boolean setMyIdBeforeDispatch)

Method Details

getMemberConnection

public IReplicationMonitoredConnection getMemberConnection(String lookupName)

Description copied from interface: IReplicationRouter

Create new replication connection and establishes it.

Specified by:

getMemberConnection in interface IReplicationRouter

getMemberConnectionAsync

public IReplicationMonitoredConnection getMemberConnectionAsync(String lookupName)

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:

lookupName - the replication node name to create the connection to

Returns:

a connection to the specified replication node

createDirectConnection

protected IReplicationMonitoredConnection createDirectConnection(String lookupName,
 boolean connectSynchronously)

wrapDirectStubWithMonitoredConnection

protected AbstractProxyBasedReplicationMonitoredConnection<IReplicationConnectionProxy,Object> wrapDirectStubWithMonitoredConnection(boolean connectSynchronously,
 RouterStubHolder routerStubHolder)

createNewMemberConnection

protected abstract AbstractProxyBasedReplicationMonitoredConnection<T,L> createNewMemberConnection(String lookupName,
 boolean connectSynchronously)

addRemoteRouterStub

public void addRemoteRouterStub(RouterStubHolder routerStubHolder)

Specified by:

addRemoteRouterStub in interface IReplicationRouterAdmin

removeRemoteStubHolder

public void removeRemoteStubHolder(String routerLookupName)

Specified by:

removeRemoteStubHolder in interface IReplicationRouterAdmin

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 Uuid getMyUniqueId()

Specified by:

getMyUniqueId in interface IReplicationRouter

isSetMyIdBeforeDispatch

public boolean isSetMyIdBeforeDispatch()

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

Specified by:

getMyEndpointDetails in interface IReplicationRouterAdmin

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationRouter

pingStub

public void pingStub(IReplicationConnectionProxy proxy)
              throws RemoteException

Throws:

RemoteException

createStub

public IReplicationConnectionProxy createStub()

getStub

public IReplicationConnectionProxy getStub()

isClosed

public boolean isClosed()

removeUrlConnection

public void removeUrlConnection(UrlProxyBasedReplicationMonitoredConnection<T,L> connection)

removeMemberConnection

public void removeMemberConnection(MemberProxyBasedReplicationMonitoredConnection<T,L> connection)

removeDirectConnection

public void removeDirectConnection(StubBasedReplicationMonitoredConnection connection)

getConnectionMonitor

protected IConnectionMonitor<T,L> getConnectionMonitor()

getAsyncContextProvider

public IAsyncContextProvider getAsyncContextProvider()

hasExistingConnection

public boolean hasExistingConnection(String lookupName)

getAdmin

public IReplicationRouterAdmin getAdmin()

Specified by:

getAdmin in interface IReplicationRouter

getMyRouterStubHolder

public RouterStubHolder getMyRouterStubHolder()

Specified by:

getMyRouterStubHolder in interface IReplicationRouterAdmin

getRemoteRouterStub

public RouterStubHolder getRemoteRouterStub(String routerLookupName)

Specified by:

getRemoteRouterStub in interface IReplicationRouterAdmin

enableIncomingCommunication

public void enableIncomingCommunication()

Specified by:

enableIncomingCommunication in interface IReplicationRouterAdmin