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

Class LocalClusterReplicationMetadataEventHandler

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationInDataTypeCreatedHandler, IReplicationInDataTypeIndexAddedHandler

public class LocalClusterReplicationMetadataEventHandler
extends AbstractLocalClusterReplicationInHandler
implements IReplicationInDataTypeCreatedHandler, IReplicationInDataTypeIndexAddedHandler

A handler for metadata events replicated to a gateway sink component.

Since:

8.0.3

Author:

idan

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

_config, _spaceProxy

Constructor Summary

Constructors

Constructor and Description
LocalClusterReplicationMetadataEventHandler(ISpaceProxy spaceProxy, ITransactionManagerProvider txnManagerProvider, LocalClusterReplicationSinkConfig config)

Method Summary

Modifier and Type	Method and Description
void	inDataTypeAddIndex(IReplicationInContext context, AddTypeIndexesRequestInfo requestInfo)
void	inDataTypeIntroduce(IReplicationInContext context, ITypeDesc typeDesc)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

execute, executeIfUidPresent, executeTransactional, extractSourceGatewayName, getSpaceProxy, handleChangeEntry, handleRemoveEntry, handleRemoveEntryByUid, handleUpdateEntry, handleWriteEntry, invokeConflictResolver

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalClusterReplicationMetadataEventHandler

public LocalClusterReplicationMetadataEventHandler(ISpaceProxy spaceProxy,
                                                   ITransactionManagerProvider txnManagerProvider,
                                                   LocalClusterReplicationSinkConfig config)

Method Detail

inDataTypeIntroduce

public void inDataTypeIntroduce(IReplicationInContext context,
                                ITypeDesc typeDesc)
                         throws Exception

Specified by:

inDataTypeIntroduce in interface IReplicationInDataTypeCreatedHandler

Throws:

Exception

inDataTypeAddIndex

public void inDataTypeAddIndex(IReplicationInContext context,
                               AddTypeIndexesRequestInfo requestInfo)
                        throws Exception

Specified by:

inDataTypeAddIndex in interface IReplicationInDataTypeIndexAddedHandler

Throws:

Exception