com.gigaspaces.internal.events.durable

Class ReplicationNotificationInBatchConsumptionHandler

java.lang.Object

com.gigaspaces.internal.events.durable.ReplicationNotificationInBatchConsumptionHandler

All Implemented Interfaces:

IReplicationInBatchConsumptionHandler

public class ReplicationNotificationInBatchConsumptionHandler
extends Object
implements IReplicationInBatchConsumptionHandler

Since:

9.0

Author:

Dan Kilman

Constructor Summary

Constructors

Constructor and Description
ReplicationNotificationInBatchConsumptionHandler(NotifyInfo notifyInfo, ITemplatePacket templatePacket, ReplicationNotificationClientEndpoint endpoint)

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 java.lang.Object

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

Constructor Detail

ReplicationNotificationInBatchConsumptionHandler

public ReplicationNotificationInBatchConsumptionHandler(NotifyInfo notifyInfo,
                                                        ITemplatePacket templatePacket,
                                                        ReplicationNotificationClientEndpoint endpoint)

Method Detail

consumePendingOperationsInBatch

public void consumePendingOperationsInBatch(IReplicationInBatchContext context)

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