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

Class ReplicationConnectionDelegator

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.gateway.lus.LusExportedReplicationComponent

com.gigaspaces.internal.cluster.node.impl.gateway.delegator.ReplicationConnectionDelegator

All Implemented Interfaces:

IReplicationLookupRegistrationListener, IConnectionStateListener, IIncomingReplicationHandler

public class ReplicationConnectionDelegator
extends LusExportedReplicationComponent
implements IIncomingReplicationHandler, IConnectionStateListener

Delegates incoming replication to a different replication connection The source of this connection proxy "thinks" he is working directly with the delegated target

Since:

8.0.2

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ReplicationConnectionDelegator.ReverseConnection

Constructor Summary

Constructors

Constructor and Description
ReplicationConnectionDelegator(String mySiteName, String targetLookupName, String routingLookupName, IReplicationLookupFinderService finderService, IReplicationLookupRegistrationService registrationService, IReplicationLookupParameters lookupParametersTemplate, IReplicationLookupParameters registrationParameters, IServiceExporter serviceExporter)

Method Summary

Modifier and Type	Method and Description
protected void	afterRegistrationInitiated() Called once the component is registration at the lookup service is initiated.
String	dumpState()
ReplicationConnectionDelegatorStatistics	getStatistics()
String	getTargetLookupName()
protected void	onClose()
void	onConnected(boolean newTarget)
void	onDisconnected()
protected <T> T	onDispatch(AbstractReplicationPacket<T> packet) Called once an incoming packet is dispatched
void	onRegistered()
<T> T	onReplication(AbstractReplicationPacket<T> packet) Handles incoming replication packet

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.lus.LusExportedReplicationComponent

close, dispatch, dispatchAsync, getMyLookupName, getMyRegistrationParameters, getMySiteName, getMyUuid, getServiceExporter, initRegistration, isAvailable

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationConnectionDelegator

public ReplicationConnectionDelegator(String mySiteName,
                                      String targetLookupName,
                                      String routingLookupName,
                                      IReplicationLookupFinderService finderService,
                                      IReplicationLookupRegistrationService registrationService,
                                      IReplicationLookupParameters lookupParametersTemplate,
                                      IReplicationLookupParameters registrationParameters,
                                      IServiceExporter serviceExporter)

Method Detail

getTargetLookupName

public String getTargetLookupName()

onDispatch

protected <T> T onDispatch(AbstractReplicationPacket<T> packet)
                    throws RemoteException

Description copied from class: LusExportedReplicationComponent

Called once an incoming packet is dispatched

Specified by:

onDispatch in class LusExportedReplicationComponent

Throws:

RemoteException

afterRegistrationInitiated

protected void afterRegistrationInitiated()

Description copied from class: LusExportedReplicationComponent

Called once the component is registration at the lookup service is initiated.

Specified by:

afterRegistrationInitiated in class LusExportedReplicationComponent

onRegistered

public void onRegistered()

Specified by:

onRegistered in interface IReplicationLookupRegistrationListener

onConnected

public void onConnected(boolean newTarget)

Specified by:

onConnected in interface IConnectionStateListener

onDisconnected

public void onDisconnected()

Specified by:

onDisconnected in interface IConnectionStateListener

onClose

protected void onClose()

Overrides:

onClose in class LusExportedReplicationComponent

onReplication

public <T> T onReplication(AbstractReplicationPacket<T> packet)
                    throws RemoteException

Description copied from interface: IIncomingReplicationHandler

Handles incoming replication packet

Specified by:

onReplication in interface IIncomingReplicationHandler

Parameters:

packet - incoming packet

Returns:

incoming replication result

Throws:

RemoteException

getStatistics

public ReplicationConnectionDelegatorStatistics getStatistics()

dumpState

public String dumpState()