Package com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class ReplicationSink

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.gateway.sink.ReplicationSink

All Implemented Interfaces:

IReplicationLookupRegistrationListener

public class ReplicationSink
extends LusExportedReplicationComponent

Acts as a sink for incoming replication

Since:

8.0.3

Author:

eitany

Field Summary

Fields

Modifier and Type	Field	Description
static final String	LOOKUP_NAME_PREFIX

Constructor Summary

Constructors

Constructor	Description
ReplicationSink(String myLookupName, IReplicationLookupRegistrationService lookupService, IReplicationLookupParameters registrationParameters, IServiceExporter serviceExporter, IIncomingReplicationFacadeProvider nodeProvider)

Method Summary

Modifier and Type	Method	Description
protected void	afterRegistrationInitiated()	Called once the component is registration at the lookup service is initiated.
protected void	onClose()
protected <T> T	onDispatch(AbstractReplicationPacket<T> packet)	Called once an incoming packet is dispatched
void	onRegistered()

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

Field Details

LOOKUP_NAME_PREFIX

public static final String LOOKUP_NAME_PREFIX

See Also:

• Constant Field Values

Constructor Details

ReplicationSink

public ReplicationSink(String myLookupName,
 IReplicationLookupRegistrationService lookupService,
 IReplicationLookupParameters registrationParameters,
 IServiceExporter serviceExporter,
 IIncomingReplicationFacadeProvider nodeProvider)

Method Details

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

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

onClose

protected void onClose()

Overrides:

onClose in class LusExportedReplicationComponent