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

Class LusExportedReplicationComponent

java.lang.Object

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

All Implemented Interfaces:

IReplicationLookupRegistrationListener

Direct Known Subclasses:

ReplicationConnectionDelegator, ReplicationSink

public abstract class LusExportedReplicationComponent
extends Object
implements IReplicationLookupRegistrationListener

Base class for replication components that are exported via the IReplicationLookupService This component can be a target of replication connection IReplicationConnectionProxy

Since:

8.0.3

Author:

eitany

Constructor Summary

Constructors

Constructor and Description
LusExportedReplicationComponent(String myLookupName, String mySiteName, IServiceExporter serviceExporter, IReplicationLookupRegistrationService lookupService, IReplicationLookupParameters lookupParametersTemplate)

Method Summary

Modifier and Type	Method and Description
protected abstract void	afterRegistrationInitiated() Called once the component is registration at the lookup service is initiated.
void	close()
<T> T	dispatch(AbstractReplicationPacket<T> packet)
<T> T	dispatchAsync(AbstractReplicationPacket<T> packet)
String	getMyLookupName()
IReplicationLookupParameters	getMyRegistrationParameters()
String	getMySiteName()
Uuid	getMyUuid()
IServiceExporter	getServiceExporter()
void	initRegistration() Initialize registration via the lookup service, this method is non blocking, once the registration is initiated afterRegistrationInitiated() is called.
protected boolean	isAvailable()
protected void	onClose()
protected abstract <T> T	onDispatch(AbstractReplicationPacket<T> packet) Called once an incoming packet is dispatched

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.gateway.lus.IReplicationLookupRegistrationListener

onRegistered

Constructor Detail

LusExportedReplicationComponent

public LusExportedReplicationComponent(String myLookupName,
                                       String mySiteName,
                                       IServiceExporter serviceExporter,
                                       IReplicationLookupRegistrationService lookupService,
                                       IReplicationLookupParameters lookupParametersTemplate)

Method Detail

initRegistration

public void initRegistration()

Initialize registration via the lookup service, this method is non blocking, once the registration is initiated afterRegistrationInitiated() is called.

getServiceExporter

public IServiceExporter getServiceExporter()

getMyRegistrationParameters

public IReplicationLookupParameters getMyRegistrationParameters()

getMyLookupName

public String getMyLookupName()

getMySiteName

public String getMySiteName()

isAvailable

protected boolean isAvailable()

getMyUuid

public Uuid getMyUuid()

close

public void close()

onClose

protected void onClose()

dispatch

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

Throws:

RemoteException

dispatchAsync

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

Throws:

RemoteException

onDispatch

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

Called once an incoming packet is dispatched

Throws:

RemoteException

afterRegistrationInitiated

protected abstract void afterRegistrationInitiated()

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