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

Class LocalClusterReplicationInBatchConsumptionHandler

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationInBatchConsumptionHandler

public class LocalClusterReplicationInBatchConsumptionHandler
extends AbstractLocalClusterReplicationInHandler
implements IReplicationInBatchConsumptionHandler

Since:

9.0

Author:

idan, eitany

Field Summary

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

_config, _spaceProxy

Constructor Summary

Constructors

Constructor and Description
LocalClusterReplicationInBatchConsumptionHandler(ISpaceProxy spaceProxy, ITransactionManagerProvider transactionManagerProvider, LocalClusterReplicationSinkConfig config)

Method Summary

Modifier and Type	Method and Description
void	consumePendingOperationsInBatch(IReplicationInBatchContext context) Called after all the incoming replication events for the current batch passed through the corresponding event handlers.

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

LocalClusterReplicationInBatchConsumptionHandler

public LocalClusterReplicationInBatchConsumptionHandler(ISpaceProxy spaceProxy,
                                                        ITransactionManagerProvider transactionManagerProvider,
                                                        LocalClusterReplicationSinkConfig config)

Method Detail

consumePendingOperationsInBatch

public void consumePendingOperationsInBatch(IReplicationInBatchContext context)
                                     throws Exception

Description copied from interface: IReplicationInBatchConsumptionHandler

Called after all the incoming replication events for the current batch passed through the corresponding event handlers. Any pending unconsumed events should be consumed here.

Specified by:

consumePendingOperationsInBatch in interface IReplicationInBatchConsumptionHandler

Throws:

Exception