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 and Description
static String	LOOKUP_NAME_PREFIX

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

LOOKUP_NAME_PREFIX

public static final String LOOKUP_NAME_PREFIX

See Also:

Constant Field Values

Constructor Detail

ReplicationSink

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

Method Detail

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